Class cascading.cascade.ParallelCascadePlatformTest

2

tests

0

failures

0

ignored

2m55.73s

duration

100%

successful

Tests

Test Duration Result
testCascade 2m35.38s passed
testCascadeRaceCondition 20.354s passed

Standard output

2016-01-14 17:03:46,465 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:03:46,487 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-tez
2016-01-14 17:03:46,511 INFO  tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-01-14 17:03:47,217 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-01-14 17:03:48,136 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 17:03:48,668 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:51,280 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-01-14 17:03:51,500 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceInit(121)) - Set TEZ-LIB-URI to: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:03:51,506 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceInit(152)) - mkdir: hdfs://localhost:44782/apps_staging_dir
2016-01-14 17:03:51,869 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-01-14 17:03:51,968 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-01-14 17:03:52,018 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-01-14 17:03:52,073 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-01-14 17:03:52,078 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceStart(186)) - Starting MiniTezCluster
2016-01-14 17:03:52,349 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:52,353 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:52,354 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:57,727 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceStart(205)) - Setting yarn-site.xml via YARN-APP-CP at: /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/target/cascading.platform.tez.Hadoop2TezPlatform,/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/resources/test:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/main:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/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.0.4/f8041cf548c12cc6e997a63a67562fcf5b2e237/cascading-core-3.0.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-platform/3.0.4/2c7c4ae0a2ac3b7e296414816e065fb601e9be39/cascading-platform-3.0.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/4f45ecd85538b8cc8c352ccd4f33c52c1776a545/cascading-hadoop2-tez-3.0.4-tests.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.1/872b4fd3a6d8a4f0bdfb0f6e26c4499e752ce39/jgrapht-core-0.9.1.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/cascading/cascading-core/3.0.4/db7694f29f171efa077bb0192f3c3039f7514807/cascading-core-3.0.4.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/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.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/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-01-14 17:03:57,985 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:58,166 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:58,166 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:03:58,219 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 17:03:58,341 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:03:58,342 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:58,415 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 864F081D4883416F9F5D5E1CE1A8476E
2016-01-14 17:03:58,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.070
2016-01-14 17:03:58,578 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.080
2016-01-14 17:03:58,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:58,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:58,580 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:58,884 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2016-01-14 17:03:58,884 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2016-01-14 17:03:58,884 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:03:58,885 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2016-01-14 17:03:58,941 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:03:58,941 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:59,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:03:59,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 17:03:59,036 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:59,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:59,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:59,088 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2016-01-14 17:03:59,090 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  parallel execution of flows is enabled: false
2016-01-14 17:03:59,090 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  executing total flows: 1
2016-01-14 17:03:59,090 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...]  allocating management threads: 1
2016-01-14 17:03:59,091 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2016-01-14 17:03:59,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] at least one sink is marked for delete
2016-01-14 17:03:59,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:03:59,111 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/D8BEB94F007F4F9DA209240162E14E7C/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:59,138 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2016-01-14 17:03:59,139 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2016-01-14 17:03:59,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping all jobs
2016-01-14 17:03:59,166 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2016-01-14 17:03:59,166 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-50/first-nondeter...] getDagStatus returned null
2016-01-14 17:03:59,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...] stopped all jobs
2016-01-14 17:03:59,167 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2016-01-14 17:03:59,167 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2016-01-14 17:03:59,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-50/first-nondeter...]  completed in: 16814:17:03:59.165
2016-01-14 17:03:59,170 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2016-01-14 17:03:59,171 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2016-01-14 17:03:59,205 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:03:59,206 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:59,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:03:59,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-14 17:03:59,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:59,339 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:59,339 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:59,404 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2016-01-14 17:03:59,405 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:03:59,406 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  executing total flows: 1
2016-01-14 17:03:59,406 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...]  allocating management threads: 1
2016-01-14 17:03:59,408 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2016-01-14 17:03:59,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] at least one sink is marked for delete
2016-01-14 17:03:59,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:03:59,414 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/7088E9567DBC476E82C4E0E25B479E9D/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:59,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting
2016-01-14 17:03:59,449 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:03:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2016-01-14 17:03:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:03:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  executing total steps: 1
2016-01-14 17:03:59,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  allocating management threads: 1
2016-01-14 17:03:59,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-01-14 17:03:59,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] tez session mode enabled: false
2016-01-14 17:03:59,487 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-01-14 17:03:59,504 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2016-01-14 17:03:59,504 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2016-01-14 17:03:59,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping all jobs
2016-01-14 17:03:59,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-01-14 17:03:59,505 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-100/first-nondete...] getDagStatus returned null
2016-01-14 17:03:59,698 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:03:59,729 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0001
2016-01-14 17:03:59,730 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:03:59,749 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/7088E9567DBC476E82C4E0E25B479E9D/C360842C95894D5098C01CC573056995/.tez/application_1452791032079_0001 doesn't exist and is created
2016-01-14 17:03:59,914 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0001, dagName=[7088E9567DBC476E82C4E0E25B479E9D/C360842C95894D5098C01CC573056995] race-100/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-01-14 17:04:00,199 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0001/
2016-01-14 17:04:00,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] stopped all jobs
2016-01-14 17:04:00,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutting down job executor
2016-01-14 17:04:00,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] submitted tez dag to app master: application_1452791032079_0001, with dag id: dag_1452791032079_0001_1
2016-01-14 17:04:00,394 INFO  client.TimelineReaderFactory (TimelineReaderFactory.java:tokenDelegationSupported(381)) - Could not find class required for token delegation, will fallback to pseudo auth
2016-01-14 17:04:00,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...] shutdown complete
2016-01-14 17:04:00,398 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2016-01-14 17:04:00,399 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2016-01-14 17:04:00,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-100/first-nondete...]  completed in: 00:00.055
2016-01-14 17:04:00,402 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2016-01-14 17:04:00,405 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2016-01-14 17:04:00,441 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:00,442 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:00,508 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 17:04:00,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-01-14 17:04:00,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:00,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:00,530 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:00,580 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2016-01-14 17:04:00,583 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:00,583 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  executing total flows: 1
2016-01-14 17:04:00,583 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:00,583 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2016-01-14 17:04:00,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:00,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:00,591 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/5D26CECEC1134350B579535C119ED30E/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:00,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting
2016-01-14 17:04:00,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:00,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2016-01-14 17:04:00,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:00,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  executing total steps: 1
2016-01-14 17:04:00,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:00,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:00,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:00,656 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-01-14 17:04:00,730 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2016-01-14 17:04:00,732 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2016-01-14 17:04:00,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping all jobs
2016-01-14 17:04:00,733 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:00,733 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-150/first-nondete...] getDagStatus returned null
2016-01-14 17:04:00,807 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:00,809 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0002
2016-01-14 17:04:00,810 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:00,830 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/5D26CECEC1134350B579535C119ED30E/A3B68AA91EBB438B8115DCC5790F7CF6/.tez/application_1452791032079_0002 doesn't exist and is created
2016-01-14 17:04:00,935 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0002, dagName=[5D26CECEC1134350B579535C119ED30E/A3B68AA91EBB438B8115DCC5790F7CF6] race-150/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-01-14 17:04:00,942 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0002/
2016-01-14 17:04:01,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] stopped all jobs
2016-01-14 17:04:01,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutting down job executor
2016-01-14 17:04:01,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] submitted tez dag to app master: application_1452791032079_0002, with dag id: dag_1452791032079_0002_1
2016-01-14 17:04:01,130 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...] shutdown complete
2016-01-14 17:04:01,130 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2016-01-14 17:04:01,132 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2016-01-14 17:04:01,137 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-150/first-nondete...]  completed in: 00:00.106
2016-01-14 17:04:01,137 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2016-01-14 17:04:01,140 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2016-01-14 17:04:01,193 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:01,193 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:01,269 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 17:04:01,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 17:04:01,301 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:01,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:01,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:01,349 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2016-01-14 17:04:01,350 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:01,351 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  executing total flows: 1
2016-01-14 17:04:01,351 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:01,351 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2016-01-14 17:04:01,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:01,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:01,359 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/C17E42F6F373484896E9891767F8C05F/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:01,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting
2016-01-14 17:04:01,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:01,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2016-01-14 17:04:01,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:01,407 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  executing total steps: 1
2016-01-14 17:04:01,407 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:01,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:01,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:01,434 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-01-14 17:04:01,549 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2016-01-14 17:04:01,550 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2016-01-14 17:04:01,551 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping all jobs
2016-01-14 17:04:01,551 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:01,552 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-200/first-nondete...] getDagStatus returned null
2016-01-14 17:04:01,569 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:01,571 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0003
2016-01-14 17:04:01,571 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:01,594 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/C17E42F6F373484896E9891767F8C05F/FB8F77DDDE4645E0A2FED59B07BA5148/.tez/application_1452791032079_0003 doesn't exist and is created
2016-01-14 17:04:01,694 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0003, dagName=[C17E42F6F373484896E9891767F8C05F/FB8F77DDDE4645E0A2FED59B07BA5148] race-200/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-01-14 17:04:01,701 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0003/
2016-01-14 17:04:01,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] stopped all jobs
2016-01-14 17:04:01,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutting down job executor
2016-01-14 17:04:01,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] submitted tez dag to app master: application_1452791032079_0003, with dag id: dag_1452791032079_0003_1
2016-01-14 17:04:01,852 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...] shutdown complete
2016-01-14 17:04:01,852 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2016-01-14 17:04:01,853 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2016-01-14 17:04:01,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-200/first-nondete...]  completed in: 00:00.148
2016-01-14 17:04:01,861 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2016-01-14 17:04:01,861 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2016-01-14 17:04:01,898 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:01,898 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:01,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 17:04:01,988 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 17:04:01,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:01,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:01,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:02,054 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2016-01-14 17:04:02,058 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:02,058 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  executing total flows: 1
2016-01-14 17:04:02,058 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:02,059 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2016-01-14 17:04:02,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:02,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:02,065 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/F0BBA3434DC14B1B987B0D697CE6E4AB/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:02,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting
2016-01-14 17:04:02,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:02,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2016-01-14 17:04:02,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:02,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  executing total steps: 1
2016-01-14 17:04:02,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:02,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:02,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:02,139 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-01-14 17:04:02,264 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:02,266 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0004
2016-01-14 17:04:02,266 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:02,284 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/F0BBA3434DC14B1B987B0D697CE6E4AB/CD14402787294CF9833BE171F4C701A6/.tez/application_1452791032079_0004 doesn't exist and is created
2016-01-14 17:04:02,304 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2016-01-14 17:04:02,305 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2016-01-14 17:04:02,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping all jobs
2016-01-14 17:04:02,306 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:02,306 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-250/first-nondete...] getDagStatus returned null
2016-01-14 17:04:02,377 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0004, dagName=[F0BBA3434DC14B1B987B0D697CE6E4AB/CD14402787294CF9833BE171F4C701A6] race-250/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-01-14 17:04:02,385 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0004/
2016-01-14 17:04:02,509 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] stopped all jobs
2016-01-14 17:04:02,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutting down job executor
2016-01-14 17:04:02,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] submitted tez dag to app master: application_1452791032079_0004, with dag id: dag_1452791032079_0004_1
2016-01-14 17:04:02,516 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...] shutdown complete
2016-01-14 17:04:02,516 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2016-01-14 17:04:02,516 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2016-01-14 17:04:02,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-250/first-nondete...]  completed in: 00:00.198
2016-01-14 17:04:02,519 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2016-01-14 17:04:02,520 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2016-01-14 17:04:02,558 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:02,558 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:02,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:04:02,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:04:02,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:02,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:02,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:02,680 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2016-01-14 17:04:02,681 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:02,681 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  executing total flows: 1
2016-01-14 17:04:02,682 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:02,682 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2016-01-14 17:04:02,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:02,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:02,687 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/1EF13F6FCB1C49FD868DCE2D9CB4B1F9/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:02,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting
2016-01-14 17:04:02,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:02,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2016-01-14 17:04:02,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:02,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  executing total steps: 1
2016-01-14 17:04:02,726 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:02,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:02,751 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:02,757 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-01-14 17:04:02,885 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:02,888 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0005
2016-01-14 17:04:02,888 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:02,907 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/1EF13F6FCB1C49FD868DCE2D9CB4B1F9/EE5EBD285237463692902861C0CC2080/.tez/application_1452791032079_0005 doesn't exist and is created
2016-01-14 17:04:02,980 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2016-01-14 17:04:02,981 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2016-01-14 17:04:02,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping all jobs
2016-01-14 17:04:02,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:02,982 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-300/first-nondete...] getDagStatus returned null
2016-01-14 17:04:03,009 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0005, dagName=[1EF13F6FCB1C49FD868DCE2D9CB4B1F9/EE5EBD285237463692902861C0CC2080] race-300/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-01-14 17:04:03,021 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0005/
2016-01-14 17:04:03,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] stopped all jobs
2016-01-14 17:04:03,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] shutting down job executor
2016-01-14 17:04:03,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] submitted tez dag to app master: application_1452791032079_0005, with dag id: dag_1452791032079_0005_1
2016-01-14 17:04:03,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...] shutdown complete
2016-01-14 17:04:03,184 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2016-01-14 17:04:03,184 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2016-01-14 17:04:03,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-300/first-nondete...]  completed in: 00:00.256
2016-01-14 17:04:03,195 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2016-01-14 17:04:03,195 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2016-01-14 17:04:03,233 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:03,234 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:03,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 17:04:03,309 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 17:04:03,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:03,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:03,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:03,352 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2016-01-14 17:04:03,353 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:03,354 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  executing total flows: 1
2016-01-14 17:04:03,354 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:03,355 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2016-01-14 17:04:03,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:03,356 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:03,360 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/069FB020357747E98243800AE8B9B489/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:03,413 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting
2016-01-14 17:04:03,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:03,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2016-01-14 17:04:03,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:03,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  executing total steps: 1
2016-01-14 17:04:03,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:03,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:03,440 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:03,445 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-01-14 17:04:03,592 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:03,593 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0006
2016-01-14 17:04:03,594 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:03,614 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/069FB020357747E98243800AE8B9B489/E3C3B022F23B457FBB9BCC8517665A18/.tez/application_1452791032079_0006 doesn't exist and is created
2016-01-14 17:04:03,702 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2016-01-14 17:04:03,703 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2016-01-14 17:04:03,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping all jobs
2016-01-14 17:04:03,704 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:03,704 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-350/first-nondete...] getDagStatus returned null
2016-01-14 17:04:03,716 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0006, dagName=[069FB020357747E98243800AE8B9B489/E3C3B022F23B457FBB9BCC8517665A18] race-350/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-01-14 17:04:03,724 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0006/
2016-01-14 17:04:03,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] stopped all jobs
2016-01-14 17:04:03,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutting down job executor
2016-01-14 17:04:03,896 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] submitted tez dag to app master: application_1452791032079_0006, with dag id: dag_1452791032079_0006_1
2016-01-14 17:04:03,901 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...] shutdown complete
2016-01-14 17:04:03,902 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2016-01-14 17:04:03,902 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2016-01-14 17:04:03,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-350/first-nondete...]  completed in: 00:00.290
2016-01-14 17:04:03,905 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2016-01-14 17:04:03,905 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2016-01-14 17:04:03,942 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:03,943 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:04,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 17:04:04,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 17:04:04,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:04,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:04,044 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:04,087 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2016-01-14 17:04:04,096 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:04,096 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  executing total flows: 1
2016-01-14 17:04:04,096 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:04,097 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2016-01-14 17:04:04,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:04,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:04,103 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/D4112CCE6D8046A69AE6A582B018DAA3/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:04,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting
2016-01-14 17:04:04,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:04,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2016-01-14 17:04:04,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:04,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  executing total steps: 1
2016-01-14 17:04:04,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:04,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:04,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:04,192 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-01-14 17:04:04,400 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:04,404 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0007
2016-01-14 17:04:04,406 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:04,433 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/D4112CCE6D8046A69AE6A582B018DAA3/DA8E9E28E6DD4893AA4AAC24209B440F/.tez/application_1452791032079_0007 doesn't exist and is created
2016-01-14 17:04:04,487 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2016-01-14 17:04:04,492 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2016-01-14 17:04:04,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping all jobs
2016-01-14 17:04:04,505 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:04,505 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-400/first-nondete...] getDagStatus returned null
2016-01-14 17:04:04,581 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0007, dagName=[D4112CCE6D8046A69AE6A582B018DAA3/DA8E9E28E6DD4893AA4AAC24209B440F] race-400/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-01-14 17:04:04,588 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0007/
2016-01-14 17:04:04,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] stopped all jobs
2016-01-14 17:04:04,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] submitted tez dag to app master: application_1452791032079_0007, with dag id: dag_1452791032079_0007_1
2016-01-14 17:04:04,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutting down job executor
2016-01-14 17:04:04,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...] shutdown complete
2016-01-14 17:04:04,748 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2016-01-14 17:04:04,748 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2016-01-14 17:04:04,752 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-400/first-nondete...]  completed in: 00:00.337
2016-01-14 17:04:04,752 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2016-01-14 17:04:04,752 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2016-01-14 17:04:04,802 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:04,802 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:04,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:04:04,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 17:04:04,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:04,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:04,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:04,996 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2016-01-14 17:04:04,997 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:04,998 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  executing total flows: 1
2016-01-14 17:04:04,998 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:04,999 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2016-01-14 17:04:05,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:05,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:05,005 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/89E050C1F0DF4404B295028F11391657/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:05,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting
2016-01-14 17:04:05,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:05,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2016-01-14 17:04:05,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:05,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  executing total steps: 1
2016-01-14 17:04:05,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:05,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:05,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:05,126 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-01-14 17:04:05,323 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:05,326 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0008
2016-01-14 17:04:05,326 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:05,348 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/89E050C1F0DF4404B295028F11391657/B41E4E6CAEA94A92B7F1E77B1FD3546C/.tez/application_1452791032079_0008 doesn't exist and is created
2016-01-14 17:04:05,446 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2016-01-14 17:04:05,450 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2016-01-14 17:04:05,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping all jobs
2016-01-14 17:04:05,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-01-14 17:04:05,458 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-450/first-nondete...] getDagStatus returned null
2016-01-14 17:04:05,479 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0008, dagName=[89E050C1F0DF4404B295028F11391657/B41E4E6CAEA94A92B7F1E77B1FD3546C] race-450/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-01-14 17:04:05,486 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0008/
2016-01-14 17:04:05,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] stopped all jobs
2016-01-14 17:04:05,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutting down job executor
2016-01-14 17:04:05,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] submitted tez dag to app master: application_1452791032079_0008, with dag id: dag_1452791032079_0008_1
2016-01-14 17:04:05,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...] shutdown complete
2016-01-14 17:04:05,662 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2016-01-14 17:04:05,663 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2016-01-14 17:04:05,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-450/first-nondete...]  completed in: 00:00.358
2016-01-14 17:04:05,667 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2016-01-14 17:04:05,667 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2016-01-14 17:04:05,710 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:05,711 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:05,828 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:04:05,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.075
2016-01-14 17:04:05,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:05,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:05,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:05,938 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2016-01-14 17:04:05,940 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  parallel execution of flows is enabled: false
2016-01-14 17:04:05,941 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  executing total flows: 1
2016-01-14 17:04:05,941 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:05,942 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2016-01-14 17:04:05,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] at least one sink is marked for delete
2016-01-14 17:04:05,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:05,947 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/2E28FD13968B428FB08CC7EFC6C48509/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:06,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting
2016-01-14 17:04:06,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:06,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2016-01-14 17:04:06,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  parallel execution of steps is enabled: true
2016-01-14 17:04:06,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  executing total steps: 1
2016-01-14 17:04:06,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  allocating management threads: 1
2016-01-14 17:04:06,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:06,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] tez session mode enabled: false
2016-01-14 17:04:06,118 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-01-14 17:04:06,378 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:06,380 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0009
2016-01-14 17:04:06,380 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:06,421 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/2E28FD13968B428FB08CC7EFC6C48509/BB8F8F594C5B4B8197B166B78483D385/.tez/application_1452791032079_0009 doesn't exist and is created
2016-01-14 17:04:06,438 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2016-01-14 17:04:06,439 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2016-01-14 17:04:06,439 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping all jobs
2016-01-14 17:04:06,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-01-14 17:04:06,441 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [race-500/first-nondete...] getDagStatus returned null
2016-01-14 17:04:06,625 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0009, dagName=[2E28FD13968B428FB08CC7EFC6C48509/BB8F8F594C5B4B8197B166B78483D385] race-500/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-01-14 17:04:06,637 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0009/
2016-01-14 17:04:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] stopped all jobs
2016-01-14 17:04:06,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] submitted tez dag to app master: application_1452791032079_0009, with dag id: dag_1452791032079_0009_1
2016-01-14 17:04:06,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutting down job executor
2016-01-14 17:04:06,838 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...] shutdown complete
2016-01-14 17:04:06,840 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2016-01-14 17:04:06,840 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2016-01-14 17:04:06,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [race-500/first-nondete...]  completed in: 00:00.402
2016-01-14 17:04:06,843 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2016-01-14 17:04:06,843 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2016-01-14 17:04:06,844 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2016-01-14 17:04:06,845 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2016-01-14 17:04:06,847 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2016-01-14 17:04:06,848 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2016-01-14 17:04:06,849 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2016-01-14 17:04:06,850 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2016-01-14 17:04:06,851 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2016-01-14 17:04:06,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2016-01-14 17:04:06,854 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2016-01-14 17:04:06,855 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2016-01-14 17:04:06,856 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2016-01-14 17:04:06,901 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:06,901 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:06,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-01-14 17:04:06,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 17:04:07,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,001 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:07,076 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:07,077 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:07,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:04:07,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 17:04:07,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:07,267 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:07,267 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:07,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:04:07,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 17:04:07,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:07,405 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:07,406 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:07,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:04:07,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:04:07,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:04:07,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:07,565 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:04:07,566 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:07,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-01-14 17:04:07,730 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.089
2016-01-14 17:04:07,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 17:04:07,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 17:04:07,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:04:08,139 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2016-01-14 17:04:08,148 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  parallel execution of flows is enabled: true
2016-01-14 17:04:08,149 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  executing total flows: 5
2016-01-14 17:04:08,149 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...]  allocating management threads: 5
2016-01-14 17:04:08,159 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2016-01-14 17:04:08,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] at least one sink is marked for delete
2016-01-14 17:04:08,160 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:08,167 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2016-01-14 17:04:08,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] at least one sink is marked for delete
2016-01-14 17:04:08,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:04:08,168 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/59ADA919FBF3406D9603FABBC18EDC21/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:08,188 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/01CC232D63DD432FBF864C6DF675ACC8/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:04:08,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting
2016-01-14 17:04:08,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting
2016-01-14 17:04:08,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:08,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-01-14 17:04:08,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  parallel execution of steps is enabled: true
2016-01-14 17:04:08,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  executing total steps: 1
2016-01-14 17:04:08,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  allocating management threads: 1
2016-01-14 17:04:08,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/ips.20.txt"]
2016-01-14 17:04:08,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-01-14 17:04:08,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  parallel execution of steps is enabled: true
2016-01-14 17:04:08,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  executing total steps: 1
2016-01-14 17:04:08,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  allocating management threads: 1
2016-01-14 17:04:08,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2016-01-14 17:04:08,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2016-01-14 17:04:08,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] tez session mode enabled: false
2016-01-14 17:04:08,341 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] tez session mode enabled: false
2016-01-14 17:04:08,347 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-01-14 17:04:08,358 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-01-14 17:04:08,518 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:08,521 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0010
2016-01-14 17:04:08,521 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:08,548 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/59ADA919FBF3406D9603FABBC18EDC21/F5E0F138BE6948B1B290AD374265605C/.tez/application_1452791032079_0010 doesn't exist and is created
2016-01-14 17:04:08,599 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:04:08,615 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0011
2016-01-14 17:04:08,615 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:04:08,636 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/01CC232D63DD432FBF864C6DF675ACC8/C468E44152FE4DAB8ADD4E7143BC9896/.tez/application_1452791032079_0011 doesn't exist and is created
2016-01-14 17:04:08,819 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0010, dagName=[59ADA919FBF3406D9603FABBC18EDC21/F5E0F138BE6948B1B290AD374265605C] first2/(1/1) ...atform/testCascade/first2
2016-01-14 17:04:08,833 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0011, dagName=[01CC232D63DD432FBF864C6DF675ACC8/C468E44152FE4DAB8ADD4E7143BC9896] first1/(1/1) ...atform/testCascade/first1
2016-01-14 17:04:09,027 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0010/
2016-01-14 17:04:09,042 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0011/
2016-01-14 17:04:09,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1] submitted tez dag to app master: application_1452791032079_0011, with dag id: dag_1452791032079_0011_1
2016-01-14 17:04:09,350 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2] submitted tez dag to app master: application_1452791032079_0010, with dag id: dag_1452791032079_0010_1
2016-01-14 17:04:24,610 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0001_01_000002 is : 143
2016-01-14 17:04:25,598 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0001_01_000002
2016-01-14 17:04:28,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0002_01_000002 is : 143
2016-01-14 17:04:29,529 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0002_01_000002
2016-01-14 17:04:47,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0003_01_000002 is : 143
2016-01-14 17:04:48,027 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0003_01_000002
2016-01-14 17:04:51,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0004_01_000002 is : 143
2016-01-14 17:05:07,442 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0005_01_000002 is : 143
2016-01-14 17:05:12,496 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0006_01_000002 is : 143
2016-01-14 17:05:28,505 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0007_01_000002 is : 143
2016-01-14 17:05:35,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0008_01_000002 is : 143
2016-01-14 17:05:36,266 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0008_01_000002
2016-01-14 17:05:51,159 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0009_01_000002 is : 143
2016-01-14 17:05:51,779 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-01-14 17:05:51,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first2]  completed in: 01:43.494, using cpu time: 00:03.020
2016-01-14 17:05:51,781 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2016-01-14 17:05:51,781 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2016-01-14 17:05:51,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] at least one sink is marked for delete
2016-01-14 17:05:51,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:05:51,785 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/427D5C3C01B74BB18D5D1E3D5DA63BF9/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:05:51,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting
2016-01-14 17:05:51,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-01-14 17:05:51,807 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-01-14 17:05:51,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  parallel execution of steps is enabled: true
2016-01-14 17:05:51,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  executing total steps: 1
2016-01-14 17:05:51,809 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  allocating management threads: 1
2016-01-14 17:05:51,810 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2016-01-14 17:05:51,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] tez session mode enabled: false
2016-01-14 17:05:51,828 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-01-14 17:05:51,923 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:05:51,924 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0012
2016-01-14 17:05:51,925 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:05:51,934 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/427D5C3C01B74BB18D5D1E3D5DA63BF9/CC5D61E1329345A59268DF675585D59A/.tez/application_1452791032079_0012 doesn't exist and is created
2016-01-14 17:05:51,990 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0012, dagName=[427D5C3C01B74BB18D5D1E3D5DA63BF9/CC5D61E1329345A59268DF675585D59A] second2/(1/1) ...tform/testCascade/second2
2016-01-14 17:05:51,993 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0012/
2016-01-14 17:05:52,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2] submitted tez dag to app master: application_1452791032079_0012, with dag id: dag_1452791032079_0012_1
2016-01-14 17:05:56,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0010_01_000002 is : 143
2016-01-14 17:05:57,774 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0010_01_000002
2016-01-14 17:06:09,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [first1]  completed in: 02:01.141, using cpu time: 00:03.150
2016-01-14 17:06:09,427 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2016-01-14 17:06:09,428 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2016-01-14 17:06:09,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] at least one sink is marked for delete
2016-01-14 17:06:09,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:06:09,432 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/C9F7EFAC864D4E0893544F2AB3DDA78D/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:06:09,457 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting
2016-01-14 17:06:09,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-01-14 17:06:09,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-01-14 17:06:09,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  parallel execution of steps is enabled: true
2016-01-14 17:06:09,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  executing total steps: 1
2016-01-14 17:06:09,459 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  allocating management threads: 1
2016-01-14 17:06:09,460 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2016-01-14 17:06:09,481 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] tez session mode enabled: false
2016-01-14 17:06:09,486 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-01-14 17:06:09,598 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:06:09,599 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0013
2016-01-14 17:06:09,599 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:06:09,610 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/C9F7EFAC864D4E0893544F2AB3DDA78D/C2360BB9CF5B4A24954A378220D4EED9/.tez/application_1452791032079_0013 doesn't exist and is created
2016-01-14 17:06:09,681 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0013, dagName=[C9F7EFAC864D4E0893544F2AB3DDA78D/C2360BB9CF5B4A24954A378220D4EED9] second1/(1/1) ...tform/testCascade/second1
2016-01-14 17:06:09,885 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0013/
2016-01-14 17:06:09,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1] submitted tez dag to app master: application_1452791032079_0013, with dag id: dag_1452791032079_0013_1
2016-01-14 17:06:14,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second2]  completed in: 00:22.407, using cpu time: 00:02.780
2016-01-14 17:06:14,215 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2016-01-14 17:06:14,453 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0011_01_000002 is : 143
2016-01-14 17:06:15,442 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452791032079_0011_01_000002
2016-01-14 17:06:19,249 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0012_01_000002 is : 143
2016-01-14 17:06:27,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [second1]  completed in: 00:18.283, using cpu time: 00:02.640
2016-01-14 17:06:27,741 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2016-01-14 17:06:27,742 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2016-01-14 17:06:27,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] at least one sink is marked for delete
2016-01-14 17:06:27,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:06:27,745 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:44782/user/teamcity/.staging/EB75DF5214AF4DA2B1A4FF3E56B32403/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:06:27,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/third"]
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 1
2016-01-14 17:06:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 1
2016-01-14 17:06:27,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2016-01-14 17:06:27,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tez session mode enabled: false
2016-01-14 17:06:27,784 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-01-14 17:06:27,861 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:06:27,862 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452791032079_0014
2016-01-14 17:06:27,862 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:44782/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:06:27,872 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:44782/user/teamcity/.staging/EB75DF5214AF4DA2B1A4FF3E56B32403/E79F3FE746184B359391BF2258B8AAAB/.tez/application_1452791032079_0014 doesn't exist and is created
2016-01-14 17:06:27,930 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452791032079_0014, dagName=[EB75DF5214AF4DA2B1A4FF3E56B32403/E79F3FE746184B359391BF2258B8AAAB] lhs*rhs/(1/1) ...latform/testCascade/third
2016-01-14 17:06:27,933 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:47585/proxy/application_1452791032079_0014/
2016-01-14 17:06:28,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted tez dag to app master: application_1452791032079_0014, with dag id: dag_1452791032079_0014_1
2016-01-14 17:06:32,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452791032079_0013_01_000002 is : 143
2016-01-14 17:06:42,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 00:14.381, using cpu time: 00:06.070
2016-01-14 17:06:42,147 INFO  cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2016-01-14 17:06:42,216 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/third
2016-01-14 17:06:42,221 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/second1
2016-01-14 17:06:42,226 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/first2
2016-01-14 17:06:42,230 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/first1
2016-01-14 17:06:42,235 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/parallelcascadeplatform/testCascade/second2

Standard error

Jan 14, 2016 5:03:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:03:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jan 14, 2016 5:03:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:03:53 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:03:53 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:54 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:54 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 5:03:54 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 5:03:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:03:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:03:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:03:55 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:03:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:55 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:56 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:03:56 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:56 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:56 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 5:03:57 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jan 14, 2016 5:03:57 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:03:57 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jan 14, 2016 5:03:57 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:03:58 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:58 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:58 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:03:58 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jan 14, 2016 5:04:09 PM com.google.inject.servlet.InternalServletModule$BackwardsCompatibleServletContextProvider get
WARNING: You are attempting to use a deprecated API (specifically, attempting to @Inject ServletContext inside an eagerly created singleton. While we allow this for backwards compatibility, be warned that this MAY have unexpected behavior if you have more than one injector (with ServletModule) running in the same JVM. Please consult the Guice documentation at http://code.google.com/p/google-guice/wiki/Servlets for more information.
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.YarnJacksonJaxbJsonProvider as a provider class
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.applicationhistoryservice.webapp.AHSWebServices as a root resource class
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.timeline.webapp.TimelineWebServices as a root resource class
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jan 14, 2016 5:04:09 PM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:04:09 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.YarnJacksonJaxbJsonProvider to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:04:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.applicationhistoryservice.webapp.AHSWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jan 14, 2016 5:04:10 PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.timeline.webapp.TimelineWebServices to GuiceManagedComponentProvider with the scope "Singleton"