2016-05-18 00:49:53,247 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 00:49:53,268 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.flow.hadoop.FlowPlatformTest, with platform: hadoop2-tez
2016-05-18 00:49:53,296 INFO tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-05-18 00:49:54,129 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-05-18 00:49:55,020 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 00:49:58,081 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(119)) - Using Tez AppJar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.8.2/bb35daf757685063ef9951dc0724f99c70f2742b/tez-dag-0.8.2.jar
2016-05-18 00:49:58,726 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(131)) - Set TEZ-LIB-URI to: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:49:58,733 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(162)) - mkdir: hdfs://localhost:43702/apps_staging_dir
2016-05-18 00:49:59,186 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 00:49:59,320 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 00:49:59,380 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 00:49:59,446 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-05-18 00:49:59,451 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(196)) - Starting MiniTezCluster
2016-05-18 00:50:05,116 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(215)) - Setting yarn-site.xml via YARN-APP-CP at: /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/target/cascading.platform.tez.Hadoop2TezPlatform,/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/resources/test:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/main:/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/resources/main:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.1.0/9f41bc3c02048b244161c34aab73acda810c2389/cascading-core-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-platform/3.1.0/38cd2eba8dbbc1efc3f097f196965a60c99cbf2f/cascading-platform-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/11d23daa35c4c17d09d6a8d13b7964dbabd56bf6/cascading-hadoop2-tez-3.1.0-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez-stats/3.1.0/2b8a4fba885da289dd195ea1f6840a76b16f77a6/cascading-hadoop2-tez-stats-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-io/3.1.0/32191afb3963b6ad8992408fd1432cd213fd8de6/cascading-hadoop2-io-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-core/2.6.4/8c00a4dbde105cd33a5ca5198eb659a4239cf990/hadoop-mapreduce-client-core-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.6.4/56eb6c8d2495b789f09986d7078c5d025e04e737/hadoop-common-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-minicluster/2.6.4/417b0c0ef24209383734e515b62687cbcd865a3b/hadoop-minicluster-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-tests/0.8.2/112a1aad7d4380d9e254adb4eaffb8d494446f1e/tez-tests-0.8.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-api/0.8.2/bb64787749c15ab156f1975d77e47f18d4291c59/tez-api-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.8.2/bb35daf757685063ef9951dc0724f99c70f2742b/tez-dag-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-aws/2.6.4/89198d72fb0da62347d8ee9b5933050c107ef423/hadoop-aws-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-yarn-timeline-history-with-acls/0.8.2/ae32d0fdc09027bb300818f11cc10bfe34e0f69/tez-yarn-timeline-history-with-acls-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/junit/junit/4.12/2973d150c0dc1fefe998f834810d68f278ea58ec/junit-4.12.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/riffle/riffle/1.0.0/d991264d10c1e80f8588d2480e3f6e536e30fcb2/riffle-1.0.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.jgrapht/jgrapht-core/0.9.2/2597c1f9aa80fcfdd1f2e8ad0f0655bd768d95ca/jgrapht-core-0.9.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.1.0/ba7756e455a94ae4c9cf9a2debeb7085e46f05e5/cascading-core-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-expression/3.1.0/47daa0fd74a26bfe727c2e6c06f8b9c7e9cb91c3/cascading-expression-3.1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-common/2.6.4/66c81d74b7053cd7daf77b45487404bf25e4744e/hadoop-yarn-common-2.6.4.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.6.4/cb6adb1a43671ac34af858e541b247edb28f5d94/hadoop-annotations-2.6.4.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.2/8ad72fe39fa8c91eaaf12aadb21e0c3661fe26d5/commons-collections-3.2.2.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/com.google.code.gson/gson/2.2.4/a60a5e993c98c864010053cb901b7eab25306568/gson-2.2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-auth/2.6.4/168a0aaeafa85047aac23d02fd5b1e1e3a45ca3b/hadoop-auth-2.6.4.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.curator/curator-client/2.6.0/b9007c357ad1a78066fc6004e8b1feaa2318f6f3/curator-client-2.6.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.curator/curator-recipes/2.6.0/8736b0fc42e6bf006d585fe85c90aaa4ade5cbef/curator-recipes-2.6.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.htrace/htrace-core/3.0.4/d7461828faf28411f37f8570d896292db277d838/htrace-core-3.0.4.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.6.4/8069031e54b6f4e88c8775edd51bbe754504b591/hadoop-common-2.6.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.6.4/72c8bae9fc3925c59cea1fc044cd2f8c963d10e0/hadoop-hdfs-2.6.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.6.4/8bb4b2fc25cbe23d14d2f614623c8fe8fc72fff2/hadoop-hdfs-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-tests/2.6.4/2e4ce795758fc6a5c851648a6ac490173a183bf5/hadoop-yarn-server-tests-2.6.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.6.4/7118f385126624c9515cea8ad8c59fce956a9166/hadoop-mapreduce-client-jobclient-2.6.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.6.4/2b76539fa2fce6b0c412f82eb5cd1f9c1e86ea0b/hadoop-mapreduce-client-jobclient-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-app/2.6.4/41306a632eff55d8faa075ab4faabe2e246beb9f/hadoop-mapreduce-client-app-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-api/2.6.4/8347f9654746096bddc65d1f103aa39cb552bcb1/hadoop-yarn-api-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-hs/2.6.4/a5b5870944b739378f05de0e50341ac46fd0e286/hadoop-mapreduce-client-hs-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-common/0.8.2/4427ae19d3905803d37c76dcb7e2f17f8c6338ab/tez-common-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-library/0.8.2/6e00309eb781f9c08ccae39a91d9406f1aa384b7/tez-runtime-library-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-mapreduce/0.8.2/17fe71f2996ed752836c62df22fc4db2da9df174/tez-mapreduce-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-examples/0.8.2/dbbdf119d6c510e79b16cbfa1b5c5a717e40f842/tez-examples-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-client/2.6.4/56dcfc4241294170c64e5385eb7bba0aa8708ae7/hadoop-yarn-client-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-common/2.6.4/162de41e70b0621f3b6ef44a0ab93290855def2e/hadoop-mapreduce-client-common-2.6.4.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.apache.commons/commons-collections4/4.1/a4cf4688fe1c7e3a63aa636cc96d013af537768e/commons-collections4-4.1.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/hadoop-shim/0.8.2/a4a7eabc59821a681beed7f1b821a9a79d355b1c/hadoop-shim-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-internals/0.8.2/349ceca61655d54f721c0a2373352a78d9f6c280/tez-runtime-internals-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-web-proxy/2.6.4/6fc2594f80c01961c73c97bf3a7cd83b0eaea2ea/hadoop-yarn-server-web-proxy-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-databind/2.2.3/3ae380888029daefb91d3ecdca3a37d8cb92bc9/jackson-databind-2.2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-annotations/2.2.3/527fece4f23a457070a36c371a26d6c0208e1c3/jackson-annotations-2.2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.amazonaws/aws-java-sdk/1.7.4/2c24ccb6f1ab845a7df971951d4b41c709a6517d/aws-java-sdk-1.7.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-yarn-timeline-history/0.8.2/2e80cf54a517a6f44ca6a358ccda42527be18ac6/tez-yarn-timeline-history-0.8.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.janino/janino/2.7.6/37fde5de7edd5d7ebe075f03f4c083df2ac73dd8/janino-2.7.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.2.2/aeb3021ca93dde265796d82015beecdcff95bf09/jaxb-api-2.2.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-jaxrs/1.9.13/534d72d2b9d6199dd531dfb27083dd4844082bba/jackson-jaxrs-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-xc/1.9.13/e3480072bc95c202476ffa1de99ff7ee9149f29c/jackson-xc-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.inject/guice/3.0/9d84f15fe35e2c716a02979fb62f50a29f38aefa/guice-3.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey.contribs/jersey-guice/1.9/5963c28c47df7e5d6ad34cec80c071c368777f7b/jersey-guice-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.3/4a85963a752c0a2f715c3924bfc686865e7e1bc6/paranamer-2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.0.4.1/f88b89a5a21a466aeb0ecf0c063605bd584b4947/snappy-java-1.0.4.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/servlet-api/2.5-20081211/22bff70037e1e6fa7e6413149489552ee2064702/servlet-api-2.5-20081211.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/2.2.3-1/56baae106392040a45a06d4a41099173425da1e6/jaxb-impl-2.2.3-1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/asm/asm/3.1/c157def142714c544bdea2e6144645702adf7097/asm-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.jamesmurty.utils/java-xmlbuilder/0.4/ac5962e48cdee3a0a6e1f8e00fcb594747ac5aaf/java-xmlbuilder-0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-digester/commons-digester/1.8/dc6a73fdbd1fa3f0944e8497c6c872fa21dca37e/commons-digester-1.8.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils-core/1.8.0/175dc721f87e4bc5cc0573f990e28c3cf9117508/commons-beanutils-core-1.8.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-kerberos-codec/2.0.0-M15/1c16e4e477183641c5f0dd5cdecd27ec331bacb5/apacheds-kerberos-codec-2.0.0-M15.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.curator/curator-framework/2.6.0/81a699c39d127b5b4ff97cc77da7650b53e5b5ed/curator-framework-2.6.0.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/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/xerces/xercesImpl/2.9.1/7bc7e49ddfe4fb5f193ed37ecc96c12292c8ceb6/xercesImpl-2.9.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-common/2.6.4/7ff6ec57f06e32360ba6501356cbc897a6194791/hadoop-yarn-server-common-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-nodemanager/2.6.4/8fcaf20d6193d60c980bc62bc1141d1a9950b30d/hadoop-yarn-server-nodemanager-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-resourcemanager/2.6.4/2255ecccfea8c6658cbe97878e377fcc829900d3/hadoop-yarn-server-resourcemanager-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-shuffle/2.6.4/fcc09475d8ea4a26029c8559a0235f29b6536b31/hadoop-mapreduce-client-shuffle-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.roaringbitmap/RoaringBitmap/0.4.9/b6127ce7af078f0a215e12f36e549f74b6088f02/RoaringBitmap-0.4.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.ning/async-http-client/1.8.16/4eb67ee9494e1a649b27d8cc78c3bd3404ec2748/async-http-client-1.8.16.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-core/2.2.3/1a0113da2cab5f4c216b4e5e7c1dbfaa67087e14/jackson-core-2.2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/joda-time/joda-time/2.9.3/9e46be514a4ed60bcfbaaba88a3c668cf30476ab/joda-time-2.9.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.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/xml-apis/xml-apis/1.3.04/90b215f48fe42776c8c7f6e3509ec54e84fd65ef/xml-apis-1.3.04.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.6.4/8d5651ef05b5294265b02a9f46d1acf6a12201ce/hadoop-yarn-server-applicationhistoryservice-2.6.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.10/5b338f206827d88acd890739f400a9b7664e5984/slf4j-api-1.7.10.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/3.0.0/5871fb60dc68d67da54a663c3fd636a10a532948/jsr305-3.0.0.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/org.slf4j/slf4j-log4j12/1.7.10/b3eeae7d1765f988a1f45ea81517191315c69c9e/slf4j-log4j12-1.7.10.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/io.netty/netty/3.9.2.Final/c8c67fb7c05e8ea847461ca972bfb08d69c520ad/netty-3.9.2.Final.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.2.4/3b7f38df6de5dd8b500e602ae8c2dd5ee446f883/httpcore-4.2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.6/b7f0fc8f61ecadeb3695f0b9464755eee44374d4/commons-codec-1.6.jar
2016-05-18 00:50:05,483 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:50:05,691 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:50:05,697 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:50:05,769 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 00:50:05,858 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 5C15EB53C80A4AA1813989B061C335E8
2016-05-18 00:50:05,910 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:05,911 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:06,178 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.072
2016-05-18 00:50:06,191 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.088
2016-05-18 00:50:06,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:06,193 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:06,194 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:06,276 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 00:50:06,279 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: input/path
2016-05-18 00:50:06,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: output/path
2016-05-18 00:50:06,375 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:06,518 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:06,518 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:06,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 00:50:06,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-18 00:50:06,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:06,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:06,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:06,667 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 00:50:06,668 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: input/path
2016-05-18 00:50:06,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: output/path
2016-05-18 00:50:06,813 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:06,814 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:06,941 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-05-18 00:50:06,980 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.125
2016-05-18 00:50:06,981 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:06,981 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:06,982 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:07,354 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 00:50:07,358 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/0B7A7FCE7E1A48899B1656E2ABA48403/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:07,410 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 00:50:07,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 00:50:07,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/upper.txt"]
2016-05-18 00:50:07,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:07,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testFailingListenerCompleted/COMPLETED/stopped"]
2016-05-18 00:50:07,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 00:50:07,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 00:50:07,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 00:50:07,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...mpleted/COMPLETED/stopped
2016-05-18 00:50:07,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tez session mode enabled: false
2016-05-18 00:50:07,449 INFO client.TezClient (TezClient.java:<init>(174)) - Tez Client Version: [ component=tez-api, version=0.8.2, revision=2d46dcefa492a6957cfa972007039f7e188760ce, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20160112-1834 ]
2016-05-18 00:50:07,825 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:50:07,977 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532599453_0001
2016-05-18 00:50:07,979 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:50:07,996 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:43702/user/teamcity/.staging/0B7A7FCE7E1A48899B1656E2ABA48403/A0928A9D19D64C2B84B504B8AB3BBF07/.tez/application_1463532599453_0001 doesn't exist and is created
2016-05-18 00:50:08,067 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:08,076 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532599453_0001
2016-05-18 00:50:08,228 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532599453_0001, dagName=[0B7A7FCE7E1A48899B1656E2ABA48403/A0928A9D19D64C2B84B504B8AB3BBF07] lower*upper/(1/1) ...mpleted/COMPLETED/stopped
2016-05-18 00:50:08,516 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:48955/proxy/application_1463532599453_0001/
2016-05-18 00:50:14,507 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:14,720 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:14,887 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:14,994 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,133 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,219 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,341 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,402 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted tez dag to app master: application_1463532599453_0001, with dag id: dag_1463532599453_0001_1
2016-05-18 00:50:15,532 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:15,612 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:17,802 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:20,529 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:20,816 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:23,351 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:23,484 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:23,617 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:23,693 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:23,953 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:24,055 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:24,424 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:24,463 INFO counters.Limits (Limits.java:ensureInitialized(60)) - Counter limits initialized with parameters: GROUP_NAME_MAX=256, MAX_GROUPS=500, COUNTER_NAME_MAX=64, MAX_COUNTERS=1200
2016-05-18 00:50:24,470 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testFailingListenerCompleted/COMPLETED/stopped/_temporary
2016-05-18 00:50:24,472 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@2d68ef77 threw throwable
java.lang.RuntimeException: intentionally failed on: COMPLETED
at cascading.flow.FailingFlowListener.onCompleted(FailingFlowListener.java:61)
at cascading.flow.BaseFlow$SafeFlowListener.onCompleted(BaseFlow.java:1703)
at cascading.flow.BaseFlow.fireOnCompleted(BaseFlow.java:1424)
at cascading.flow.BaseFlow.run(BaseFlow.java:1281)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 00:50:24,473 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:24,474 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...mpleted/COMPLETED/stopped
2016-05-18 00:50:24,476 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:24,477 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:17.055, using cpu time: 00:08.280
2016-05-18 00:50:24,477 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testFailingListenerCompleted/COMPLETED/stopped
2016-05-18 00:50:24,499 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:24,534 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:24,534 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:24,641 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 00:50:24,680 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.097
2016-05-18 00:50:24,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:24,681 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:24,682 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:24,964 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 00:50:24,966 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/AD0BDA4058E64307873B3EFDF476E5C6/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:24,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 00:50:24,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/upper.txt"]
2016-05-18 00:50:24,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:24,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testFailingListenerThrowable/THROWABLE/stopped"]
2016-05-18 00:50:24,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 00:50:24,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 00:50:24,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 00:50:24,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...rowable/THROWABLE/stopped
2016-05-18 00:50:25,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tez session mode enabled: false
2016-05-18 00:50:25,017 INFO client.TezClient (TezClient.java:<init>(174)) - Tez Client Version: [ component=tez-api, version=0.8.2, revision=2d46dcefa492a6957cfa972007039f7e188760ce, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20160112-1834 ]
2016-05-18 00:50:25,119 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:50:25,196 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532599453_0002
2016-05-18 00:50:25,197 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:50:25,213 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:43702/user/teamcity/.staging/AD0BDA4058E64307873B3EFDF476E5C6/A7A0CA379AC3426DAF56785541AD25D4/.tez/application_1463532599453_0002 doesn't exist and is created
2016-05-18 00:50:25,263 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:25,265 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532599453_0002
2016-05-18 00:50:25,348 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532599453_0002, dagName=[AD0BDA4058E64307873B3EFDF476E5C6/A7A0CA379AC3426DAF56785541AD25D4] lower*upper/(1/1) ...rowable/THROWABLE/stopped
2016-05-18 00:50:25,354 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:48955/proxy/application_1463532599453_0002/
2016-05-18 00:50:29,505 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532599453_0001_01_000003 is : 143
2016-05-18 00:50:29,508 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:29,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532599453_0001_01_000002 is : 143
2016-05-18 00:50:31,278 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:31,405 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:31,588 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:31,721 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:31,886 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:31,999 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:32,081 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:32,135 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:32,170 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted tez dag to app master: application_1463532599453_0002, with dag id: dag_1463532599453_0002_1
2016-05-18 00:50:32,183 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:34,580 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:38,674 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:38,888 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:41,301 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:41,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532599453_0002_01_000003 is : 143
2016-05-18 00:50:41,384 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:41,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:41,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...rowable/THROWABLE/stopped
2016-05-18 00:50:41,420 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:41,420 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@46b9a1cf threw throwable
java.lang.RuntimeException: intentionally failed on: THROWABLE
at cascading.flow.FailingFlowListener.onThrowable(FailingFlowListener.java:69)
at cascading.flow.BaseFlow$SafeFlowListener.onThrowable(BaseFlow.java:1715)
at cascading.flow.BaseFlow.fireOnThrowable(BaseFlow.java:1444)
at cascading.flow.BaseFlow.handleThrowableAndMarkFailed(BaseFlow.java:1336)
at cascading.flow.BaseFlow.run(BaseFlow.java:1270)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 00:50:41,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:41,424 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...rowable/THROWABLE/stopped
2016-05-18 00:50:41,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:41,431 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:16.428
2016-05-18 00:50:41,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testFailingListenerThrowable/THROWABLE/stopped
2016-05-18 00:50:41,453 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532599453_0002_01_000002 is : 143
2016-05-18 00:50:41,459 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:41,488 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:41,489 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:41,552 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:41,603 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-18 00:50:41,648 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.086
2016-05-18 00:50:41,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:41,649 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:41,650 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:41,900 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(195)) - calling start
2016-05-18 00:50:41,901 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/BEBECA7895CF4BE58A88EF903E62C3EF/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:41,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 00:50:41,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/upper.txt"]
2016-05-18 00:50:41,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:41,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testStop/stopped"]
2016-05-18 00:50:41,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 00:50:41,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 00:50:41,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 00:50:41,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...platform/testStop/stopped
2016-05-18 00:50:41,938 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tez session mode enabled: false
2016-05-18 00:50:41,941 INFO client.TezClient (TezClient.java:<init>(174)) - Tez Client Version: [ component=tez-api, version=0.8.2, revision=2d46dcefa492a6957cfa972007039f7e188760ce, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20160112-1834 ]
2016-05-18 00:50:42,028 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:50:42,100 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532599453_0003
2016-05-18 00:50:42,101 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:50:42,118 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:43702/user/teamcity/.staging/BEBECA7895CF4BE58A88EF903E62C3EF/BEC82E590EA14F539D88E6D06CEC6B70/.tez/application_1463532599453_0003 doesn't exist and is created
2016-05-18 00:50:42,147 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:42,148 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532599453_0003
2016-05-18 00:50:42,201 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532599453_0003, dagName=[BEBECA7895CF4BE58A88EF903E62C3EF/BEC82E590EA14F539D88E6D06CEC6B70] lower*upper/(1/1) ...platform/testStop/stopped
2016-05-18 00:50:42,207 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:48955/proxy/application_1463532599453_0003/
2016-05-18 00:50:46,922 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 00:50:47,922 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:47,923 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:47,923 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 00:50:48,436 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:48,542 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:48,696 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:48,800 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:48,924 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:48,924 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:48,924 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(204)) - testing if running
2016-05-18 00:50:48,940 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,008 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,060 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted tez dag to app master: application_1463532599453_0003, with dag id: dag_1463532599453_0003_1
2016-05-18 00:50:49,064 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,126 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,177 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,226 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:49,928 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:testStop(237)) - calling stop
2016-05-18 00:50:49,928 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:call(230)) - calling complete
2016-05-18 00:50:49,928 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:49,932 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...platform/testStop/stopped
2016-05-18 00:50:49,952 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:50,001 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:50,021 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-05-18 00:50:50,037 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:08.006
2016-05-18 00:50:50,037 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testStop/stopped
2016-05-18 00:50:50,042 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:50,087 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:50,087 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:50,089 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:50,141 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:50,167 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 00:50:50,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.085
2016-05-18 00:50:50,216 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:50,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:50,217 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:50,474 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 00:50:50,476 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/0B462B5239E54FE79BFD94801AC01389/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:50,501 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@613c96eb threw throwable
java.lang.RuntimeException: intentionally failed on: STARTING
at cascading.flow.FailingFlowListener.onStarting(FailingFlowListener.java:45)
at cascading.flow.BaseFlow$SafeFlowListener.onStarting(BaseFlow.java:1679)
at cascading.flow.BaseFlow.fireOnStarting(BaseFlow.java:1471)
at cascading.flow.BaseFlow.run(BaseFlow.java:1219)
at cascading.flow.BaseFlow.access$100(BaseFlow.java:82)
at cascading.flow.BaseFlow$1.run(BaseFlow.java:928)
at java.lang.Thread.run(Thread.java:745)
2016-05-18 00:50:50,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:50,502 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...Starting/STARTING/stopped
2016-05-18 00:50:50,503 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:50,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:50,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 00:50:50,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/upper.txt"]
2016-05-18 00:50:50,503 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:50,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testFailingListenerStarting/STARTING/stopped"]
2016-05-18 00:50:50,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 00:50:50,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 00:50:50,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 00:50:50,504 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:00.001
2016-05-18 00:50:50,505 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testFailingListenerStarting/STARTING/stopped
2016-05-18 00:50:50,533 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:50,533 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:50,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 00:50:50,587 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 00:50:50,589 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:50:50,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:50:50,590 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:50,670 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/7F39D2D287674AC0A4EC82A566EEA291/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:50,689 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping all jobs
2016-05-18 00:50:50,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopping: (1/1) ...stStartStopRace/startstop
2016-05-18 00:50:50,690 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower] getDagStatus returned null
2016-05-18 00:50:50,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] stopped all jobs
2016-05-18 00:50:50,690 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testStartStopRace/startstop
2016-05-18 00:50:50,690 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 16939:00:50:50.689
2016-05-18 00:50:50,721 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:50,721 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:50,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 00:50:50,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-05-18 00:50:50,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:50,807 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 5
2016-05-18 00:50:50,808 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:51,060 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(391)) - calling start
2016-05-18 00:50:51,062 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/584D800B0BD14D108E4B110939EA484E/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:51,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting
2016-05-18 00:50:51,083 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:51,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/upper.txt"]
2016-05-18 00:50:51,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:51,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testFailingListenerStopping/STOPPING/stopped"]
2016-05-18 00:50:51,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] parallel execution of steps is enabled: true
2016-05-18 00:50:51,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] executing total steps: 1
2016-05-18 00:50:51,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] allocating management threads: 1
2016-05-18 00:50:51,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] starting step: (1/1) ...Stopping/STOPPING/stopped
2016-05-18 00:50:51,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] tez session mode enabled: false
2016-05-18 00:50:51,103 INFO client.TezClient (TezClient.java:<init>(174)) - Tez Client Version: [ component=tez-api, version=0.8.2, revision=2d46dcefa492a6957cfa972007039f7e188760ce, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20160112-1834 ]
2016-05-18 00:50:51,184 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:50:51,266 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532599453_0004
2016-05-18 00:50:51,266 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:50:51,281 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:43702/user/teamcity/.staging/584D800B0BD14D108E4B110939EA484E/BFA22D1380D545938EFB064FAC83326E/.tez/application_1463532599453_0004 doesn't exist and is created
2016-05-18 00:50:51,324 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:51,326 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532599453_0004
2016-05-18 00:50:51,398 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532599453_0004, dagName=[584D800B0BD14D108E4B110939EA484E/BFA22D1380D545938EFB064FAC83326E] lower*upper/(1/1) ...Stopping/STOPPING/stopped
2016-05-18 00:50:51,404 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:48955/proxy/application_1463532599453_0004/
2016-05-18 00:50:51,432 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532599453_0003_01_000002
2016-05-18 00:50:51,432 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532599453_0003_01_000003
2016-05-18 00:50:52,083 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:52,084 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:52,084 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:53,084 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:53,085 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:53,085 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:54,085 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:54,086 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:54,086 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:55,086 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:55,087 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:55,087 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:56,087 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:56,087 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:56,088 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:57,091 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:57,091 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:57,092 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:57,333 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,430 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,637 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,765 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,868 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,916 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:57,989 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:58,050 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:58,092 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:58,092 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [lower*upper] getDagStatus returned null
2016-05-18 00:50:58,093 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(400)) - testing if running
2016-05-18 00:50:58,104 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:58,152 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:58,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] submitted tez dag to app master: application_1463532599453_0004, with dag id: dag_1463532599453_0004_1
2016-05-18 00:50:59,095 INFO hadoop.FlowPlatformTest (FlowPlatformTest.java:failingListenerTest(417)) - calling stop
2016-05-18 00:50:59,095 WARN flow.Flow (BaseFlow.java:logWarn(1522)) - [lower*upper] flow listener cascading.flow.FailingFlowListener@5267e846 threw throwable
java.lang.RuntimeException: intentionally failed on: STOPPING
at cascading.flow.FailingFlowListener.onStopping(FailingFlowListener.java:53)
at cascading.flow.BaseFlow$SafeFlowListener.onStopping(BaseFlow.java:1691)
at cascading.flow.BaseFlow.fireOnStopping(BaseFlow.java:1459)
at cascading.flow.BaseFlow.stop(BaseFlow.java:948)
at cascading.flow.hadoop.FlowPlatformTest.failingListenerTest(FlowPlatformTest.java:419)
at cascading.flow.hadoop.FlowPlatformTest.testFailingListenerStopping(FlowPlatformTest.java:328)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:303)
at cascading.platform.PlatformRunner.runChild(PlatformRunner.java:69)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:86)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:49)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:64)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:50)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at org.gradle.messaging.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:106)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.messaging.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.messaging.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:360)
at org.gradle.internal.concurrent.DefaultExecutorFactory$StoppableExecutorImpl$1.run(DefaultExecutorFactory.java:64)
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-05-18 00:50:59,096 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping all jobs
2016-05-18 00:50:59,097 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopping: (1/1) ...Stopping/STOPPING/stopped
2016-05-18 00:50:59,118 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] stopped all jobs
2016-05-18 00:50:59,160 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:59,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] did not capture all completed node details, will retry in 00:00.010, prior retries: 0
2016-05-18 00:50:59,201 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower*upper] completed in: 00:08.013
2016-05-18 00:50:59,201 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testFailingListenerStopping/STOPPING/stopped
2016-05-18 00:50:59,232 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:59,250 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:59,250 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:59,280 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:59,297 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-05-18 00:50:59,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 00:50:59,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:59,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:59,306 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:59,323 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via sink: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["output/path"]
2016-05-18 00:50:59,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: output/path
2016-05-18 00:50:59,358 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:59,359 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:59,402 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-05-18 00:50:59,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 00:50:59,411 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:59,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:50:59,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:59,482 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:50:59,482 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:59,521 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-05-18 00:50:59,533 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 00:50:59,534 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:50:59,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:50:59,535 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:50:59,649 INFO util.HadoopUtil (HadoopUtil.java:syncPaths(556)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar, to: hdfs://localhost:43702/user/teamcity/.staging/C316D8B141D440D3AD9BB986C55600A5/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:50:59,668 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting
2016-05-18 00:50:59,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/lower.txt"]
2016-05-18 00:50:59,669 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testStartWithoutComplete/withoutcomplete"]
2016-05-18 00:50:59,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] parallel execution of steps is enabled: true
2016-05-18 00:50:59,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executing total steps: 1
2016-05-18 00:50:59,670 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] allocating management threads: 1
2016-05-18 00:50:59,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] starting step: (1/1) ...tComplete/withoutcomplete
2016-05-18 00:50:59,692 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] tez session mode enabled: false
2016-05-18 00:50:59,695 INFO client.TezClient (TezClient.java:<init>(174)) - Tez Client Version: [ component=tez-api, version=0.8.2, revision=2d46dcefa492a6957cfa972007039f7e188760ce, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20160112-1834 ]
2016-05-18 00:50:59,803 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:50:59,876 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532599453_0005
2016-05-18 00:50:59,876 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:43702/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:50:59,889 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:43702/user/teamcity/.staging/C316D8B141D440D3AD9BB986C55600A5/F3E8887F5ED94CC9A6344CA2E8796576/.tez/application_1463532599453_0005 doesn't exist and is created
2016-05-18 00:50:59,918 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:50:59,919 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532599453_0005
2016-05-18 00:50:59,968 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532599453_0005, dagName=[C316D8B141D440D3AD9BB986C55600A5/F3E8887F5ED94CC9A6344CA2E8796576] lower/(1/1) ...tComplete/withoutcomplete
2016-05-18 00:50:59,975 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:48955/proxy/application_1463532599453_0005/
2016-05-18 00:51:00,445 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532599453_0004_01_000002
2016-05-18 00:51:00,445 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532599453_0004_01_000003
2016-05-18 00:51:06,315 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,407 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,635 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,732 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,871 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,920 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:06,964 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:07,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] submitted tez dag to app master: application_1463532599453_0005, with dag id: dag_1463532599453_0005_1
2016-05-18 00:51:08,567 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:10,488 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,149 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,190 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,264 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,655 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,694 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/flowplatform/testStartWithoutComplete/withoutcomplete/_temporary
2016-05-18 00:51:12,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testStartWithoutComplete/withoutcomplete
2016-05-18 00:51:12,696 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] completed in: 00:13.024, using cpu time: 00:03.560
2016-05-18 00:51:12,727 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:51:12,734 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:51:12,735 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:51:12,777 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:51:12,783 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 00:51:12,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:51:12,784 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:51:12,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:51:12,801 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 00:51:12,801 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: input/path
2016-05-18 00:51:12,802 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: output/path
2016-05-18 00:51:12,850 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:51:12,851 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:51:12,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.007
2016-05-18 00:51:12,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.013
2016-05-18 00:51:12,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:51:12,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:51:12,910 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:51:12,926 INFO hadoop.Hfs (Hfs.java:makeLocal(445)) - forcing job to stand-alone mode, via source: Lfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["input/path"]
2016-05-18 00:51:12,926 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: input/path
2016-05-18 00:51:12,927 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [test] tap forcing step to tez local mode: output/path
2016-05-18 00:51:12,963 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:51:12,964 INFO planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(151)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.1.0/226af02e24d5195c60e4ebe911d0c7c9780f59f0/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:51:13,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:51:13,012 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.019
2016-05-18 00:51:13,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:51:13,013 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-05-18 00:51:13,014 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lower] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:51:13,061 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output//hadoop2-tez/flowplatform/testFailedSerialization/badserialization