2016-01-14 17:01:27,758 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:01:27,786 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.cascade.CascadePlatformTest, with platform: hadoop2-tez
2016-01-14 17:01:27,822 INFO tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-01-14 17:01:28,527 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:01:29,344 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 17:01:29,827 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:32,675 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:01:32,884 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(121)) - Set TEZ-LIB-URI to: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:01:32,891 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(152)) - mkdir: hdfs://localhost:46273/apps_staging_dir
2016-01-14 17:01:33,321 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:01:33,421 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:01:33,473 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:01:33,525 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:01:33,531 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(186)) - Starting MiniTezCluster
2016-01-14 17:01:33,805 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:33,808 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:33,810 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:39,165 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:01:39,440 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:39,660 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:39,660 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 17:01:39,716 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2016-01-14 17:01:39,838 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:39,839 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:01:39,910 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5B54C7D76C8F4FCEBFA4843C24DA4B31
2016-01-14 17:01:40,033 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.058
2016-01-14 17:01:40,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-01-14 17:01:40,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,049 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:40,298 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:40,299 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:01:40,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:01:40,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-01-14 17:01:40,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:40,588 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:40,589 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:01:40,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 17:01:40,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.050
2016-01-14 17:01:40,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,704 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:40,819 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:40,820 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:01:40,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:01:40,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 17:01:40,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:40,914 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:40,977 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:01:40,977 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-01-14 17:01:40,983 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] parallel execution of flows is enabled: true
2016-01-14 17:01:40,984 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] executing total flows: 4
2016-01-14 17:01:40,984 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] allocating management threads: 4
2016-01-14 17:01:40,984 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-01-14 17:01:40,986 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: first
2016-01-14 17:01:40,987 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: second
2016-01-14 17:01:40,987 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: second
2016-01-14 17:01:40,989 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: third
2016-01-14 17:01:40,989 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: third
2016-01-14 17:01:40,990 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: fourth
2016-01-14 17:01:40,990 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] skipping flow: fourth
2016-01-14 17:01:41,008 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/cascadeplatform/testSkippedCascade/skipped/fourth
2016-01-14 17:01:41,009 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/cascadeplatform/testSkippedCascade/skipped/first
2016-01-14 17:01:41,010 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/cascadeplatform/testSkippedCascade/skipped/third
2016-01-14 17:01:41,011 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/cascadeplatform/testSkippedCascade/skipped/second
2016-01-14 17:01:41,053 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:41,054 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:01:41,119 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:01:41,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-01-14 17:01:41,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,142 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:41,218 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:41,219 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:01:41,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:01:41,295 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 17:01:41,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:41,364 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:01:41,364 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:01:41,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-01-14 17:01:41,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 17:01:41,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:01:41,422 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:01:41,462 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting
2016-01-14 17:01:41,463 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] parallel execution of flows is enabled: true
2016-01-14 17:01:41,464 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] executing total flows: 3
2016-01-14 17:01:41,464 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] allocating management threads: 3
2016-01-14 17:01:41,465 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-second
2016-01-14 17:01:41,465 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: previous-multi-tap-first
2016-01-14 17:01:41,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] at least one sink is marked for delete
2016-01-14 17:01:41,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] at least one sink is marked for delete
2016-01-14 17:01:41,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:01:41,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:01:41,473 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:46273/user/teamcity/.staging/E185631A10AE425D84081E1AB838FBE3/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:01:41,474 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:46273/user/teamcity/.staging/FE6C0C97A57B4E29B2DE6137AAAE49B1/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:01:41,551 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] starting
2016-01-14 17:01:41,552 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] 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:01:41,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testMultiTapCascade/multitap/second"]
2016-01-14 17:01:41,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] parallel execution of steps is enabled: true
2016-01-14 17:01:41,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] executing total steps: 1
2016-01-14 17:01:41,554 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] allocating management threads: 1
2016-01-14 17:01:41,552 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] starting
2016-01-14 17:01:41,555 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] 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:01:41,555 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testMultiTapCascade/multitap/first"]
2016-01-14 17:01:41,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] starting step: (1/1) ...apCascade/multitap/second
2016-01-14 17:01:41,556 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] parallel execution of steps is enabled: true
2016-01-14 17:01:41,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] executing total steps: 1
2016-01-14 17:01:41,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] allocating management threads: 1
2016-01-14 17:01:41,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] starting step: (1/1) ...TapCascade/multitap/first
2016-01-14 17:01:41,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] tez session mode enabled: false
2016-01-14 17:01:41,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] tez session mode enabled: false
2016-01-14 17:01:41,595 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:01:41,595 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:01:41,860 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:01:41,860 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:01:41,893 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0002
2016-01-14 17:01:41,893 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0001
2016-01-14 17:01:41,895 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:01:41,895 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:01:41,924 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/E185631A10AE425D84081E1AB838FBE3/B33459BAB53D4FD29EA2530E19ED7033/.tez/application_1452790893533_0001 doesn't exist and is created
2016-01-14 17:01:41,929 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/FE6C0C97A57B4E29B2DE6137AAAE49B1/AA0265E9F77B40AA8399CBE1DC71E3F3/.tez/application_1452790893533_0002 doesn't exist and is created
2016-01-14 17:01:42,133 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0002, dagName=[FE6C0C97A57B4E29B2DE6137AAAE49B1/AA0265E9F77B40AA8399CBE1DC71E3F3] previous-multi-tap-first/(1/1) ...TapCascade/multitap/first
2016-01-14 17:01:42,133 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0001, dagName=[E185631A10AE425D84081E1AB838FBE3/B33459BAB53D4FD29EA2530E19ED7033] previous-multi-tap-second/(1/1) ...apCascade/multitap/second
2016-01-14 17:01:42,207 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0002/
2016-01-14 17:01:42,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] submitted tez dag to app master: application_1452790893533_0002, with dag id: dag_1452790893533_0002_1
2016-01-14 17:01:42,424 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0001/
2016-01-14 17:01:42,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] submitted tez dag to app master: application_1452790893533_0001, with dag id: dag_1452790893533_0001_1
2016-01-14 17:01:59,745 INFO client.TimelineReaderFactory (TimelineReaderFactory.java:tokenDelegationSupported(381)) - Could not find class required for token delegation, will fallback to pseudo auth
2016-01-14 17:01:59,781 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:01:59,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-second] completed in: 00:18.231, using cpu time: 00:02.980
2016-01-14 17:01:59,784 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-second
2016-01-14 17:02:02,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [previous-multi-tap-first] completed in: 00:20.863, using cpu time: 00:02.760
2016-01-14 17:02:02,416 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: previous-multi-tap-first
2016-01-14 17:02:02,417 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] starting flow: multi-tap
2016-01-14 17:02:02,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] at least one sink is marked for delete
2016-01-14 17:02:02,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:02:02,423 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:46273/user/teamcity/.staging/24C3D49AB7544A85937A2CFE5E2D4073/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:02:02,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] starting
2016-01-14 17:02:02,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testMultiTapCascade/multitap/first"], Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testMultiTapCascade/multitap/second"]]]
2016-01-14 17:02:02,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] 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/cascadeplatform/testMultiTapCascade/multitap/multitap"]
2016-01-14 17:02:02,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] parallel execution of steps is enabled: true
2016-01-14 17:02:02,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] executing total steps: 1
2016-01-14 17:02:02,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] allocating management threads: 1
2016-01-14 17:02:02,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] starting step: (1/1) ...Cascade/multitap/multitap
2016-01-14 17:02:02,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] tez session mode enabled: false
2016-01-14 17:02:02,472 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:02:02,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:02:02,571 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0003
2016-01-14 17:02:02,572 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:02:02,587 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/24C3D49AB7544A85937A2CFE5E2D4073/B105299CA084471688D8434D7A82D05E/.tez/application_1452790893533_0003 doesn't exist and is created
2016-01-14 17:02:02,656 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0003, dagName=[24C3D49AB7544A85937A2CFE5E2D4073/B105299CA084471688D8434D7A82D05E] multi-tap/(1/1) ...Cascade/multitap/multitap
2016-01-14 17:02:02,661 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0003/
2016-01-14 17:02:02,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] submitted tez dag to app master: application_1452790893533_0003, with dag id: dag_1452790893533_0003_1
2016-01-14 17:02:04,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0001_01_000002 is : 143
2016-01-14 17:02:07,446 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0002_01_000002 is : 143
2016-01-14 17:02:08,435 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0002_01_000002
2016-01-14 17:02:20,988 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-tap] completed in: 00:18.536, using cpu time: 00:02.930
2016-01-14 17:02:20,989 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [multi-tap+previous-mul...] completed flow: multi-tap
2016-01-14 17:02:21,059 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/cascadeplatform/testMultiTapCascade/multitap/multitap
2016-01-14 17:02:21,065 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/cascadeplatform/testMultiTapCascade/multitap/second
2016-01-14 17:02:21,071 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/cascadeplatform/testMultiTapCascade/multitap/first
2016-01-14 17:02:21,104 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:21,105 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:02:21,151 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:02:21,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:02:21,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,162 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:21,218 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:21,219 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:02:21,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-01-14 17:02:21,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 17:02:21,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:21,331 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:21,331 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:02:21,370 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-01-14 17:02:21,378 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 17:02:21,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,379 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:21,429 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:21,429 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:02:21,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 17:02:21,485 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:02:21,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:21,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:21,527 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-01-14 17:02:21,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] parallel execution of flows is enabled: true
2016-01-14 17:02:21,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] executing total flows: 4
2016-01-14 17:02:21,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] allocating management threads: 4
2016-01-14 17:02:21,529 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-01-14 17:02:21,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-14 17:02:21,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:02:21,533 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:46273/user/teamcity/.staging/6A7C0075E1B144C889F253A84E9F3571/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:02:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-14 17:02:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] 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:02:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascadeFail/simple/first"]
2016-01-14 17:02:21,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-14 17:02:21,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-14 17:02:21,558 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-14 17:02:21,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...eCascadeFail/simple/first
2016-01-14 17:02:21,572 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tez session mode enabled: false
2016-01-14 17:02:21,576 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:02:21,670 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:02:21,671 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0004
2016-01-14 17:02:21,672 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:02:21,682 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/6A7C0075E1B144C889F253A84E9F3571/D7B9F95203CB4ED7AEEA9A3C1598703F/.tez/application_1452790893533_0004 doesn't exist and is created
2016-01-14 17:02:21,752 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0004, dagName=[6A7C0075E1B144C889F253A84E9F3571/D7B9F95203CB4ED7AEEA9A3C1598703F] first/(1/1) ...eCascadeFail/simple/first
2016-01-14 17:02:21,755 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0004/
2016-01-14 17:02:21,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted tez dag to app master: application_1452790893533_0004, with dag id: dag_1452790893533_0004_1
2016-01-14 17:02:26,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0003_01_000002 is : 143
2016-01-14 17:02:27,009 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0003_01_000002
2016-01-14 17:02:35,749 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-14 17:02:35,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-01-14 17:02:35,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-14 17:02:35,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:14.194
2016-01-14 17:02:35,752 WARN cascade.Cascade (BaseCascade.java:logWarn(878)) - [fourth+second+third+first] flow failed: first
cascading.flow.FlowException: step failed: (1/1) ...eCascadeFail/simple/first, step id: D7B9F95203CB4ED7AEEA9A3C1598703F, job id: Executing on YARN cluster with App id application_1452790893533_0004, please see cluster logs for failure messages
at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:295)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2016-01-14 17:02:35,755 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping all flows
2016-01-14 17:02:35,759 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: fourth
2016-01-14 17:02:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping all jobs
2016-01-14 17:02:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping: (1/1) ...CascadeFail/simple/fourth
2016-01-14 17:02:35,761 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [fourth] getDagStatus returned null
2016-01-14 17:02:35,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopped all jobs
2016-01-14 17:02:35,761 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: third
2016-01-14 17:02:35,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping all jobs
2016-01-14 17:02:35,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping: (1/1) ...eCascadeFail/simple/third
2016-01-14 17:02:35,762 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [third] getDagStatus returned null
2016-01-14 17:02:35,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopped all jobs
2016-01-14 17:02:35,763 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: second
2016-01-14 17:02:35,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping all jobs
2016-01-14 17:02:35,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping: (1/1) ...CascadeFail/simple/second
2016-01-14 17:02:35,764 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [second] getDagStatus returned null
2016-01-14 17:02:35,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopped all jobs
2016-01-14 17:02:35,764 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopping flow: first
2016-01-14 17:02:35,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-14 17:02:35,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...eCascadeFail/simple/first
2016-01-14 17:02:35,765 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-14 17:02:35,765 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] stopped all flows
2016-01-14 17:02:35,766 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/cascadeplatform/testSimpleCascadeFail/simple/fourth
2016-01-14 17:02:35,767 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/cascadeplatform/testSimpleCascadeFail/simple/first
2016-01-14 17:02:35,771 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/cascadeplatform/testSimpleCascadeFail/simple/second
2016-01-14 17:02:35,772 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/cascadeplatform/testSimpleCascadeFail/simple/third
2016-01-14 17:02:35,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0004_01_000002 is : 143
2016-01-14 17:02:35,810 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:35,811 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:02:35,854 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-01-14 17:02:35,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:02:35,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:35,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:35,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:35,940 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:35,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:02:35,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-01-14 17:02:35,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:02:35,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:35,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:35,991 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:36,048 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:36,048 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:02:36,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-01-14 17:02:36,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:02:36,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:36,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:36,097 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:36,142 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:36,143 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:02:36,179 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-01-14 17:02:36,195 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:02:36,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:36,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:36,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
calling start
2016-01-14 17:02:36,233 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting
2016-01-14 17:02:36,234 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] parallel execution of flows is enabled: true
2016-01-14 17:02:36,234 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] executing total flows: 4
2016-01-14 17:02:36,234 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] allocating management threads: 4
2016-01-14 17:02:36,234 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] starting flow: first
2016-01-14 17:02:36,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-14 17:02:36,235 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:02:36,238 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:46273/user/teamcity/.staging/5849B109200C422481812775263E8363/cascading-hadoop2-tez-3.0.4.jar
testing if running
2016-01-14 17:02:36,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-14 17:02:36,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] 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:02:36,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic"]
2016-01-14 17:02:36,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-14 17:02:36,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-14 17:02:36,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-14 17:02:36,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2016-01-14 17:02:36,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tez session mode enabled: false
2016-01-14 17:02:36,283 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:02:36,381 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:02:36,382 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0005
2016-01-14 17:02:36,383 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:02:36,392 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/5849B109200C422481812775263E8363/F56EBB527F0440FBBD0C1058669FC0AB/.tez/application_1452790893533_0005 doesn't exist and is created
2016-01-14 17:02:36,454 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0005, dagName=[5849B109200C422481812775263E8363/F56EBB527F0440FBBD0C1058669FC0AB] first/(1/1) ...ed/first-nondeterministic
2016-01-14 17:02:36,457 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0005/
2016-01-14 17:02:36,550 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted tez dag to app master: application_1452790893533_0005, with dag id: dag_1452790893533_0005_1
2016-01-14 17:02:36,759 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0004_01_000002
testing if running
testing if running
testing if running
testing if running
testing if running
calling stop
2016-01-14 17:02:42,387 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping all flows
2016-01-14 17:02:42,388 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: fourth
2016-01-14 17:02:42,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping all jobs
2016-01-14 17:02:42,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2016-01-14 17:02:42,389 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [fourth] getDagStatus returned null
2016-01-14 17:02:42,389 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] stopped all jobs
2016-01-14 17:02:42,389 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: third
2016-01-14 17:02:42,389 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping all jobs
2016-01-14 17:02:42,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2016-01-14 17:02:42,390 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [third] getDagStatus returned null
2016-01-14 17:02:42,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] stopped all jobs
2016-01-14 17:02:42,390 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: second
2016-01-14 17:02:42,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping all jobs
2016-01-14 17:02:42,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopping: (1/1) ...d/second-nondeterministic
2016-01-14 17:02:42,391 WARN flow.Flow (BaseFlow.java:logWarn(1445)) - [second] getDagStatus returned null
2016-01-14 17:02:42,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] stopped all jobs
2016-01-14 17:02:42,391 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopping flow: first
2016-01-14 17:02:42,391 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping all jobs
2016-01-14 17:02:42,392 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2016-01-14 17:02:42,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] stopped all jobs
2016-01-14 17:02:42,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] shutting down job executor
2016-01-14 17:02:42,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-01-14 17:02:43,427 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 58
2016-01-14 17:02:44,436 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 142
2016-01-14 17:02:45,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 224
2016-01-14 17:02:46,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 304
2016-01-14 17:02:47,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 387
2016-01-14 17:02:48,458 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 470
2016-01-14 17:02:49,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] did not capture all completed node details, will retry in 00:00.010, prior retries: 561
2016-01-14 17:02:49,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:06.129
2016-01-14 17:02:49,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] shutdown complete
2016-01-14 17:02:49,970 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] stopped all flows
2016-01-14 17:02:49,970 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutting down flow executor
2016-01-14 17:02:49,970 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] completed flow: first
2016-01-14 17:02:49,973 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second+third+fourth] shutdown complete
2016-01-14 17:02:49,973 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/cascadeplatform/testSimpleCascadeStop/stopped/first-nondeterministic
2016-01-14 17:02:49,977 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/cascadeplatform/testSimpleCascadeStop/stopped/fourth-nondeterministic
2016-01-14 17:02:49,978 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/cascadeplatform/testSimpleCascadeStop/stopped/third-nondeterministic
2016-01-14 17:02:49,979 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/cascadeplatform/testSimpleCascadeStop/stopped/second-nondeterministic
2016-01-14 17:02:50,022 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:50,022 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:02:50,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:02:50,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 17:02:50,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:50,142 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:50,142 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:02:50,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-01-14 17:02:50,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 17:02:50,197 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:50,258 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:50,258 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:02:50,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.010
2016-01-14 17:02:50,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:02:50,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,302 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:50,347 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:02:50,347 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:02:50,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.010
2016-01-14 17:02:50,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-14 17:02:50,396 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:02:50,397 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:02:50,424 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting
2016-01-14 17:02:50,425 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] parallel execution of flows is enabled: true
2016-01-14 17:02:50,425 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] executing total flows: 4
2016-01-14 17:02:50,425 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] allocating management threads: 4
2016-01-14 17:02:50,426 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: first
2016-01-14 17:02:50,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2016-01-14 17:02:50,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:02:50,429 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:46273/user/teamcity/.staging/C63CB9A7138B4AFDAFB4354BD50B0F13/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:02:50,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2016-01-14 17:02:50,453 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] 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:02:50,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/first"]
2016-01-14 17:02:50,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2016-01-14 17:02:50,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2016-01-14 17:02:50,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2016-01-14 17:02:50,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...impleCascade/simple/first
2016-01-14 17:02:50,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tez session mode enabled: false
2016-01-14 17:02:50,481 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:02:50,575 INFO client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 17:02:50,576 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0006
2016-01-14 17:02:50,576 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:02:50,586 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/C63CB9A7138B4AFDAFB4354BD50B0F13/E280422FC226434FBBB47578E23FC7B9/.tez/application_1452790893533_0006 doesn't exist and is created
2016-01-14 17:02:50,646 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0006, dagName=[C63CB9A7138B4AFDAFB4354BD50B0F13/E280422FC226434FBBB47578E23FC7B9] first/(1/1) ...impleCascade/simple/first
2016-01-14 17:02:50,649 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0006/
2016-01-14 17:02:50,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted tez dag to app master: application_1452790893533_0006, with dag id: dag_1452790893533_0006_1
2016-01-14 17:02:55,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0005_01_000002 is : 143
2016-01-14 17:02:56,067 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0005_01_000002
2016-01-14 17:03:03,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:13.521, using cpu time: 00:02.700
2016-01-14 17:03:03,974 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: first
2016-01-14 17:03:03,974 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: second
2016-01-14 17:03:03,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2016-01-14 17:03:03,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:03:03,978 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:46273/user/teamcity/.staging/4A4274241CAB482EAA7204CC71A5781F/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:04,003 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2016-01-14 17:03:04,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/first"]
2016-01-14 17:03:04,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/second"]
2016-01-14 17:03:04,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] parallel execution of steps is enabled: true
2016-01-14 17:03:04,004 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executing total steps: 1
2016-01-14 17:03:04,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] allocating management threads: 1
2016-01-14 17:03:04,005 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...mpleCascade/simple/second
2016-01-14 17:03:04,019 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tez session mode enabled: false
2016-01-14 17:03:04,023 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:04,107 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:04,108 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0007
2016-01-14 17:03:04,108 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:03:04,117 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/4A4274241CAB482EAA7204CC71A5781F/FD5F0F51DBDD4CD99D62E494AA0CF33C/.tez/application_1452790893533_0007 doesn't exist and is created
2016-01-14 17:03:04,177 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0007, dagName=[4A4274241CAB482EAA7204CC71A5781F/FD5F0F51DBDD4CD99D62E494AA0CF33C] second/(1/1) ...mpleCascade/simple/second
2016-01-14 17:03:04,180 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0007/
2016-01-14 17:03:04,263 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted tez dag to app master: application_1452790893533_0007, with dag id: dag_1452790893533_0007_1
2016-01-14 17:03:09,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0006_01_000002 is : 143
2016-01-14 17:03:10,001 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0006_01_000002
2016-01-14 17:03:18,844 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] completed in: 00:14.841, using cpu time: 00:02.920
2016-01-14 17:03:18,845 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: second
2016-01-14 17:03:18,845 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: third
2016-01-14 17:03:18,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] at least one sink is marked for delete
2016-01-14 17:03:18,845 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:03:18,848 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:46273/user/teamcity/.staging/06496CC11F9D4DD8B415B0B55593B4B3/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:18,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting
2016-01-14 17:03:18,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/second"]
2016-01-14 17:03:18,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/third"]
2016-01-14 17:03:18,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] parallel execution of steps is enabled: true
2016-01-14 17:03:18,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executing total steps: 1
2016-01-14 17:03:18,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] allocating management threads: 1
2016-01-14 17:03:18,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] starting step: (1/1) ...impleCascade/simple/third
2016-01-14 17:03:18,887 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] tez session mode enabled: false
2016-01-14 17:03:18,890 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:18,977 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:18,978 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0008
2016-01-14 17:03:18,978 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:03:18,988 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/06496CC11F9D4DD8B415B0B55593B4B3/BA8292C0076A47EF9F5B7594DDE76E7B/.tez/application_1452790893533_0008 doesn't exist and is created
2016-01-14 17:03:19,048 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0008, dagName=[06496CC11F9D4DD8B415B0B55593B4B3/BA8292C0076A47EF9F5B7594DDE76E7B] third/(1/1) ...impleCascade/simple/third
2016-01-14 17:03:19,052 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0008/
2016-01-14 17:03:19,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] submitted tez dag to app master: application_1452790893533_0008, with dag id: dag_1452790893533_0008_1
2016-01-14 17:03:23,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0007_01_000002 is : 143
2016-01-14 17:03:32,442 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] completed in: 00:13.570, using cpu time: 00:02.890
2016-01-14 17:03:32,442 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: third
2016-01-14 17:03:32,443 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] starting flow: fourth
2016-01-14 17:03:32,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] at least one sink is marked for delete
2016-01-14 17:03:32,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-01-14 17:03:32,446 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:46273/user/teamcity/.staging/6CC3EAEE391448E29837B8A066A774AB/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 17:03:32,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting
2016-01-14 17:03:32,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/cascadeplatform/testSimpleCascade/simple/third"]
2016-01-14 17:03:32,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] 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/cascadeplatform/testSimpleCascade/simple/fourth"]
2016-01-14 17:03:32,469 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] parallel execution of steps is enabled: true
2016-01-14 17:03:32,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executing total steps: 1
2016-01-14 17:03:32,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] allocating management threads: 1
2016-01-14 17:03:32,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] starting step: (1/1) ...mpleCascade/simple/fourth
2016-01-14 17:03:32,484 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] tez session mode enabled: false
2016-01-14 17:03:32,488 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:32,571 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:32,572 INFO client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790893533_0009
2016-01-14 17:03:32,572 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:46273/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 17:03:32,582 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:46273/user/teamcity/.staging/6CC3EAEE391448E29837B8A066A774AB/F8C04EA8D4C342EA9CBDB440A76999C3/.tez/application_1452790893533_0009 doesn't exist and is created
2016-01-14 17:03:32,647 INFO client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790893533_0009, dagName=[6CC3EAEE391448E29837B8A066A774AB/F8C04EA8D4C342EA9CBDB440A76999C3] fourth/(1/1) ...mpleCascade/simple/fourth
2016-01-14 17:03:32,852 INFO client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:45275/proxy/application_1452790893533_0009/
2016-01-14 17:03:32,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] submitted tez dag to app master: application_1452790893533_0009, with dag id: dag_1452790893533_0009_1
2016-01-14 17:03:37,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790893533_0008_01_000002 is : 143
2016-01-14 17:03:38,463 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790893533_0008_01_000002
2016-01-14 17:03:44,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] completed in: 00:11.785, using cpu time: 00:02.570
2016-01-14 17:03:44,254 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [fourth+second+third+first] completed flow: fourth
2016-01-14 17:03:44,285 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/cascadeplatform/testSimpleCascade/simple/third
2016-01-14 17:03:44,291 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/cascadeplatform/testSimpleCascade/simple/second
2016-01-14 17:03:44,299 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/cascadeplatform/testSimpleCascade/simple/fourth
2016-01-14 17:03:44,303 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/cascadeplatform/testSimpleCascade/simple/first
2016-01-14 17:03:44,334 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:44,335 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:44,374 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-01-14 17:03:44,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 17:03:44,382 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:44,433 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:44,434 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:44,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-01-14 17:03:44,476 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 17:03:44,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,477 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:44,526 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:44,527 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:44,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 17:03:44,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 17:03:44,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,571 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [third] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:44,628 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:44,628 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:44,662 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-01-14 17:03:44,669 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:03:44,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,672 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [fourth] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:44,697 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/cascadeplatform/testCascadeID/idtest/second
2016-01-14 17:03:44,698 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/cascadeplatform/testCascadeID/idtest/first
2016-01-14 17:03:44,698 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/cascadeplatform/testCascadeID/idtest/fourth
2016-01-14 17:03:44,699 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/cascadeplatform/testCascadeID/idtest/third
2016-01-14 17:03:44,724 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:44,724 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:44,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-01-14 17:03:44,763 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 17:03:44,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,764 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 17:03:44,824 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:44,824 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:44,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-01-14 17:03:44,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-01-14 17:03:44,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:03:44,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'