2016-05-18 00:45:20,208 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 00:45:20,230 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.cascade.ParallelCascadePlatformTest, with platform: hadoop2-tez
2016-05-18 00:45:20,263 INFO tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-05-18 00:45:21,136 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:45:22,034 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-05-18 00:45:25,338 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:45:25,962 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(131)) - Set TEZ-LIB-URI to: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:45:25,968 INFO test.MiniTezCluster (MiniTezCluster.java:serviceInit(162)) - mkdir: hdfs://localhost:55357/apps_staging_dir
2016-05-18 00:45:26,359 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:45:26,469 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:45:26,538 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:45:26,606 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:45:26,612 INFO test.MiniTezCluster (MiniTezCluster.java:serviceStart(196)) - Starting MiniTezCluster
2016-05-18 00:45:32,279 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:45:32,608 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:45:32,815 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:45:32,819 ERROR delegation.AbstractDelegationTokenSecretManager (AbstractDelegationTokenSecretManager.java:run(659)) - ExpiredTokenRemover received java.lang.InterruptedException: sleep interrupted
2016-05-18 00:45:32,867 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 00:45:33,071 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:45:33,072 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:45:33,190 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 7F50A5C55ADA432A97933662E00722FD
2016-05-18 00:45:33,401 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.081
2016-05-18 00:45:33,448 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.130
2016-05-18 00:45:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:33,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:33,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-0/first-nondeterm...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:45:33,787 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopping all flows
2016-05-18 00:45:33,787 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] stopped all flows
2016-05-18 00:45:33,791 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 00:45:33,791 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-0/first-nondeterm...] starting
2016-05-18 00:45:33,796 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:33,849 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:45:33,850 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:45:33,966 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 00:45:33,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-05-18 00:45:33,994 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:33,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:33,995 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:45:34,060 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting
2016-05-18 00:45:34,063 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] parallel execution of flows is enabled: false
2016-05-18 00:45:34,063 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] executing total flows: 1
2016-05-18 00:45:34,064 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] allocating management threads: 1
2016-05-18 00:45:34,064 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2016-05-18 00:45:34,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] at least one sink is marked for delete
2016-05-18 00:45:34,065 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:45:34,084 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:55357/user/teamcity/.staging/2360B9FCFC4C42D29DC54F3B23114D64/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:45:34,110 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping all flows
2016-05-18 00:45:34,113 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2016-05-18 00:45:34,138 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping all jobs
2016-05-18 00:45:34,139 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 00:45:34,139 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-50/first-nondeter...] getDagStatus returned null
2016-05-18 00:45:34,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] stopped all jobs
2016-05-18 00:45:34,142 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] stopped all flows
2016-05-18 00:45:34,142 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutting down flow executor
2016-05-18 00:45:34,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-50/first-nondeter...] completed in: 16939:00:45:34.138
2016-05-18 00:45:34,145 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2016-05-18 00:45:34,147 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-50/first-nondeter...] shutdown complete
2016-05-18 00:45:34,207 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:45:34,207 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:45:34,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 00:45:34,279 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 00:45:34,280 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:34,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:34,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:45:34,341 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting
2016-05-18 00:45:34,342 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:45:34,343 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] executing total flows: 1
2016-05-18 00:45:34,343 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-18 00:45:34,343 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2016-05-18 00:45:34,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] at least one sink is marked for delete
2016-05-18 00:45:34,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:45:34,348 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:55357/user/teamcity/.staging/4E9505CFDFFD42C4BA2B71CE5AB198FC/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:45:34,378 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting
2016-05-18 00:45:34,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:45:34,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic"]
2016-05-18 00:45:34,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:45:34,379 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] executing total steps: 1
2016-05-18 00:45:34,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] allocating management threads: 1
2016-05-18 00:45:34,380 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 00:45:34,398 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] tez session mode enabled: false
2016-05-18 00:45:34,419 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:45:34,440 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping all flows
2016-05-18 00:45:34,441 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2016-05-18 00:45:34,441 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping all jobs
2016-05-18 00:45:34,442 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 00:45:34,443 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-100/first-nondete...] getDagStatus returned null
2016-05-18 00:45:34,822 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:45:34,909 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] stopped all jobs
2016-05-18 00:45:34,942 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0001
2016-05-18 00:45:34,943 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:45:34,960 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/4E9505CFDFFD42C4BA2B71CE5AB198FC/BADF0152AE4546188F7864C4FE22FB6E/.tez/application_1463532326614_0001 doesn't exist and is created
2016-05-18 00:45:35,059 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:35,065 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0001
2016-05-18 00:45:35,205 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0001, dagName=[4E9505CFDFFD42C4BA2B71CE5AB198FC/BADF0152AE4546188F7864C4FE22FB6E] race-100/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-18 00:45:35,493 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0001/
2016-05-18 00:45:41,450 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:41,712 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:41,910 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:42,018 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:42,224 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:42,367 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] submitted tez dag to app master: application_1463532326614_0001, with dag id: dag_1463532326614_0001_1
2016-05-18 00:45:42,442 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] stopped all flows
2016-05-18 00:45:42,442 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutting down flow executor
2016-05-18 00:45:42,442 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:45:42,443 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-100/first-nondete...] completed in: 00:00.063
2016-05-18 00:45:42,443 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2016-05-18 00:45:42,443 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-100/first-nondete...] shutdown complete
2016-05-18 00:45:42,481 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:45:42,481 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:45:42,553 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-18 00:45:42,570 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.046
2016-05-18 00:45:42,571 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:42,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:42,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:45:42,617 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting
2016-05-18 00:45:42,618 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:45:42,619 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] executing total flows: 1
2016-05-18 00:45:42,619 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-18 00:45:42,620 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2016-05-18 00:45:42,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] at least one sink is marked for delete
2016-05-18 00:45:42,620 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:45:42,625 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:55357/user/teamcity/.staging/6B02FA25D779428CA274013CC023AE2F/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:45:42,659 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting
2016-05-18 00:45:42,659 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:45:42,659 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic"]
2016-05-18 00:45:42,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:45:42,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] executing total steps: 1
2016-05-18 00:45:42,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] allocating management threads: 1
2016-05-18 00:45:42,662 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 00:45:42,679 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] tez session mode enabled: false
2016-05-18 00:45:42,683 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:45:42,767 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping all flows
2016-05-18 00:45:42,768 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2016-05-18 00:45:42,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping all jobs
2016-05-18 00:45:42,769 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 00:45:42,769 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-150/first-nondete...] getDagStatus returned null
2016-05-18 00:45:42,805 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:45:42,877 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0002
2016-05-18 00:45:42,877 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:45:42,896 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/6B02FA25D779428CA274013CC023AE2F/A8034955E60C4FEE988869039F44D1C0/.tez/application_1463532326614_0002 doesn't exist and is created
2016-05-18 00:45:42,979 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:42,981 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0002
2016-05-18 00:45:43,065 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0002, dagName=[6B02FA25D779428CA274013CC023AE2F/A8034955E60C4FEE988869039F44D1C0] race-150/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-18 00:45:43,073 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0002/
2016-05-18 00:45:43,776 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:45,966 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:48,327 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:48,438 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:50,738 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:50,920 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:51,057 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:51,185 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:51,345 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:51,368 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] submitted tez dag to app master: application_1463532326614_0002, with dag id: dag_1463532326614_0002_1
2016-05-18 00:45:51,371 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] stopped all jobs
2016-05-18 00:45:51,412 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] stopped all flows
2016-05-18 00:45:51,412 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-150/first-nondete...] completed in: 00:00.109
2016-05-18 00:45:51,413 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutting down flow executor
2016-05-18 00:45:51,413 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2016-05-18 00:45:51,413 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-150/first-nondete...] shutdown complete
2016-05-18 00:45:51,444 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:45:51,444 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:45:51,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 00:45:51,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 00:45:51,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:51,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:45:51,510 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:45:51,543 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting
2016-05-18 00:45:51,544 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:45:51,545 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] executing total flows: 1
2016-05-18 00:45:51,545 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-18 00:45:51,546 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2016-05-18 00:45:51,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] at least one sink is marked for delete
2016-05-18 00:45:51,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:45:51,550 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:55357/user/teamcity/.staging/11EA9A9759954A8BB2B1E24FB87A91A5/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:45:51,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting
2016-05-18 00:45:51,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:45:51,584 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic"]
2016-05-18 00:45:51,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:45:51,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] executing total steps: 1
2016-05-18 00:45:51,585 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] allocating management threads: 1
2016-05-18 00:45:51,588 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 00:45:51,604 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] tez session mode enabled: false
2016-05-18 00:45:51,607 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:45:51,690 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:45:51,743 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping all flows
2016-05-18 00:45:51,745 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2016-05-18 00:45:51,745 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping all jobs
2016-05-18 00:45:51,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 00:45:51,746 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-200/first-nondete...] getDagStatus returned null
2016-05-18 00:45:51,764 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0003
2016-05-18 00:45:51,764 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:45:51,781 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/11EA9A9759954A8BB2B1E24FB87A91A5/CDC5E4EE61844917BC5F22C030D1FF16/.tez/application_1463532326614_0003 doesn't exist and is created
2016-05-18 00:45:51,840 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:51,841 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0003
2016-05-18 00:45:51,916 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0003, dagName=[11EA9A9759954A8BB2B1E24FB87A91A5/CDC5E4EE61844917BC5F22C030D1FF16] race-200/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-18 00:45:51,925 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0003/
2016-05-18 00:45:52,897 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:53,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0001_01_000002 is : 143
2016-05-18 00:45:53,462 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:54,925 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:56,757 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:45:56,843 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,176 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,371 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,494 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,585 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0002_01_000002 is : 143
2016-05-18 00:46:01,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] stopped all jobs
2016-05-18 00:46:01,845 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] submitted tez dag to app master: application_1463532326614_0003, with dag id: dag_1463532326614_0003_1
2016-05-18 00:46:01,896 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,911 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] stopped all flows
2016-05-18 00:46:01,912 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:01,912 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutting down flow executor
2016-05-18 00:46:01,913 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-200/first-nondete...] completed in: 00:00.161
2016-05-18 00:46:01,914 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2016-05-18 00:46:01,914 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-200/first-nondete...] shutdown complete
2016-05-18 00:46:01,947 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:01,947 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:46:02,010 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 00:46:02,025 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-05-18 00:46:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:02,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:02,077 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting
2016-05-18 00:46:02,081 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:02,081 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] executing total flows: 1
2016-05-18 00:46:02,082 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-18 00:46:02,082 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2016-05-18 00:46:02,082 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:02,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:02,088 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:55357/user/teamcity/.staging/7B51AC0A2B1F40588A5A94D6F340613D/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:02,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting
2016-05-18 00:46:02,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:02,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic"]
2016-05-18 00:46:02,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:02,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] executing total steps: 1
2016-05-18 00:46:02,123 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] allocating management threads: 1
2016-05-18 00:46:02,125 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:02,140 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:02,143 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:46:02,225 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:02,315 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0004
2016-05-18 00:46:02,315 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:02,327 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping all flows
2016-05-18 00:46:02,329 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2016-05-18 00:46:02,329 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping all jobs
2016-05-18 00:46:02,330 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:02,330 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/7B51AC0A2B1F40588A5A94D6F340613D/D8DE718306504F84A5D4615C3083BB78/.tez/application_1463532326614_0004 doesn't exist and is created
2016-05-18 00:46:02,330 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-250/first-nondete...] getDagStatus returned null
2016-05-18 00:46:02,384 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:02,385 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0004
2016-05-18 00:46:02,435 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0004, dagName=[7B51AC0A2B1F40588A5A94D6F340613D/D8DE718306504F84A5D4615C3083BB78] race-250/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-18 00:46:02,642 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0004/
2016-05-18 00:46:03,378 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:07,515 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:09,987 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:10,109 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:10,511 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:10,669 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:10,798 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:10,894 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:11,033 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] stopped all jobs
2016-05-18 00:46:11,033 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] submitted tez dag to app master: application_1463532326614_0004, with dag id: dag_1463532326614_0004_1
2016-05-18 00:46:11,127 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] stopped all flows
2016-05-18 00:46:11,127 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-250/first-nondete...] completed in: 00:00.207
2016-05-18 00:46:11,128 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2016-05-18 00:46:11,127 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutting down flow executor
2016-05-18 00:46:11,129 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-250/first-nondete...] shutdown complete
2016-05-18 00:46:11,151 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:11,165 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:11,166 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:46:11,206 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-05-18 00:46:11,220 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-05-18 00:46:11,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:11,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:11,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:11,250 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting
2016-05-18 00:46:11,251 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:11,251 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] executing total flows: 1
2016-05-18 00:46:11,251 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-18 00:46:11,251 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2016-05-18 00:46:11,251 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:11,252 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:11,254 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:55357/user/teamcity/.staging/ECDAB71A0485474C9228E7FC1B02CB2E/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:11,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting
2016-05-18 00:46:11,281 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:11,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic"]
2016-05-18 00:46:11,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:11,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] executing total steps: 1
2016-05-18 00:46:11,282 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] allocating management threads: 1
2016-05-18 00:46:11,283 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:11,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:11,302 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:46:11,381 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:11,450 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0005
2016-05-18 00:46:11,450 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:11,465 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/ECDAB71A0485474C9228E7FC1B02CB2E/E5BC4999AF304678B615DCC06EA731A3/.tez/application_1463532326614_0005 doesn't exist and is created
2016-05-18 00:46:11,535 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:11,536 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0005
2016-05-18 00:46:11,551 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping all flows
2016-05-18 00:46:11,551 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2016-05-18 00:46:11,551 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping all jobs
2016-05-18 00:46:11,552 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:11,552 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-300/first-nondete...] getDagStatus returned null
2016-05-18 00:46:11,593 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0005, dagName=[ECDAB71A0485474C9228E7FC1B02CB2E/E5BC4999AF304678B615DCC06EA731A3] race-300/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-18 00:46:11,598 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0005/
2016-05-18 00:46:12,629 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:15,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0003_01_000002 is : 143
2016-05-18 00:46:15,084 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:15,764 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:17,721 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:17,817 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,296 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,456 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,579 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,662 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0004_01_000002 is : 143
2016-05-18 00:46:22,892 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,894 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:22,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] stopped all jobs
2016-05-18 00:46:22,933 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] submitted tez dag to app master: application_1463532326614_0005, with dag id: dag_1463532326614_0005_1
2016-05-18 00:46:22,974 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] stopped all flows
2016-05-18 00:46:22,974 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutting down flow executor
2016-05-18 00:46:22,974 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-300/first-nondete...] completed in: 00:00.270
2016-05-18 00:46:22,975 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2016-05-18 00:46:22,975 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-300/first-nondete...] shutdown complete
2016-05-18 00:46:23,001 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:23,001 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:46:23,059 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-05-18 00:46:23,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-18 00:46:23,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:23,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:23,084 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:23,118 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting
2016-05-18 00:46:23,119 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:23,119 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] executing total flows: 1
2016-05-18 00:46:23,120 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-18 00:46:23,121 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2016-05-18 00:46:23,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:23,122 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:23,128 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:55357/user/teamcity/.staging/5262D9C18F324EBE8CA596174C767C50/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:23,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting
2016-05-18 00:46:23,153 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic"]
2016-05-18 00:46:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] executing total steps: 1
2016-05-18 00:46:23,154 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] allocating management threads: 1
2016-05-18 00:46:23,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:23,171 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:23,173 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:46:23,259 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:23,329 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0006
2016-05-18 00:46:23,329 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:23,344 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/5262D9C18F324EBE8CA596174C767C50/B9CE731F8BA1436AA36D66C1AAC1F607/.tez/application_1463532326614_0006 doesn't exist and is created
2016-05-18 00:46:23,408 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:23,410 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0006
2016-05-18 00:46:23,460 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0006, dagName=[5262D9C18F324EBE8CA596174C767C50/B9CE731F8BA1436AA36D66C1AAC1F607] race-350/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-18 00:46:23,465 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0006/
2016-05-18 00:46:23,469 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping all flows
2016-05-18 00:46:23,469 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2016-05-18 00:46:23,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping all jobs
2016-05-18 00:46:23,470 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:23,470 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-350/first-nondete...] getDagStatus returned null
2016-05-18 00:46:24,507 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:28,715 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:30,764 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:30,863 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:30,955 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:31,375 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:31,535 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:31,672 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:31,747 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:31,973 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:32,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] stopped all jobs
2016-05-18 00:46:32,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] submitted tez dag to app master: application_1463532326614_0006, with dag id: dag_1463532326614_0006_1
2016-05-18 00:46:32,263 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] stopped all flows
2016-05-18 00:46:32,263 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-350/first-nondete...] completed in: 00:00.316
2016-05-18 00:46:32,263 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutting down flow executor
2016-05-18 00:46:32,263 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2016-05-18 00:46:32,264 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-350/first-nondete...] shutdown complete
2016-05-18 00:46:32,288 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:32,289 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:46:32,331 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-05-18 00:46:32,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-05-18 00:46:32,344 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:32,345 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:32,345 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:32,373 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting
2016-05-18 00:46:32,373 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:32,374 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] executing total flows: 1
2016-05-18 00:46:32,374 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-18 00:46:32,375 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2016-05-18 00:46:32,375 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:32,376 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:32,379 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:55357/user/teamcity/.staging/C9550EA205E140BC92F204004A5EA022/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:32,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting
2016-05-18 00:46:32,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:32,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic"]
2016-05-18 00:46:32,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:32,406 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] executing total steps: 1
2016-05-18 00:46:32,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] allocating management threads: 1
2016-05-18 00:46:32,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:32,422 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:32,425 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:46:32,518 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:32,585 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0007
2016-05-18 00:46:32,585 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:32,601 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/C9550EA205E140BC92F204004A5EA022/A19BAF9326454F318ABBB108D28F5BA0/.tez/application_1463532326614_0007 doesn't exist and is created
2016-05-18 00:46:32,653 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:32,655 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0007
2016-05-18 00:46:32,713 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0007, dagName=[C9550EA205E140BC92F204004A5EA022/A19BAF9326454F318ABBB108D28F5BA0] race-400/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-18 00:46:32,719 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0007/
2016-05-18 00:46:32,773 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping all flows
2016-05-18 00:46:32,773 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2016-05-18 00:46:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping all jobs
2016-05-18 00:46:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:32,774 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-400/first-nondete...] getDagStatus returned null
2016-05-18 00:46:33,538 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:35,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0005_01_000002 is : 143
2016-05-18 00:46:35,900 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:36,685 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:38,438 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:38,528 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,130 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,294 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,434 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0006_01_000002 is : 143
2016-05-18 00:46:43,606 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,609 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,801 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:43,825 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532326614_0006_01_000001
2016-05-18 00:46:43,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] stopped all jobs
2016-05-18 00:46:43,975 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] submitted tez dag to app master: application_1463532326614_0007, with dag id: dag_1463532326614_0007_1
2016-05-18 00:46:44,014 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] stopped all flows
2016-05-18 00:46:44,014 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutting down flow executor
2016-05-18 00:46:44,015 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-400/first-nondete...] completed in: 00:00.369
2016-05-18 00:46:44,015 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2016-05-18 00:46:44,015 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-400/first-nondete...] shutdown complete
2016-05-18 00:46:44,044 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:44,045 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:46:44,089 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-05-18 00:46:44,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-18 00:46:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:44,100 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:44,129 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting
2016-05-18 00:46:44,131 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:44,131 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] executing total flows: 1
2016-05-18 00:46:44,132 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-18 00:46:44,132 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2016-05-18 00:46:44,132 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:44,133 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:44,137 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:55357/user/teamcity/.staging/2080B773C17D45E3AA15FAC63992BFD8/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:44,155 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting
2016-05-18 00:46:44,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:44,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic"]
2016-05-18 00:46:44,156 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:44,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] executing total steps: 1
2016-05-18 00:46:44,157 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] allocating management threads: 1
2016-05-18 00:46:44,158 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:44,172 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:44,175 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:46:44,259 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:44,324 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0008
2016-05-18 00:46:44,324 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:44,337 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/2080B773C17D45E3AA15FAC63992BFD8/C6A4F5E846DD4ED6A94D11ED1C7FF962/.tez/application_1463532326614_0008 doesn't exist and is created
2016-05-18 00:46:44,399 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:44,400 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0008
2016-05-18 00:46:44,448 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0008, dagName=[2080B773C17D45E3AA15FAC63992BFD8/C6A4F5E846DD4ED6A94D11ED1C7FF962] race-450/first-nondeterministic/(1/1) ...50/first-nondeterministic
2016-05-18 00:46:44,453 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0008/
2016-05-18 00:46:44,579 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping all flows
2016-05-18 00:46:44,580 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2016-05-18 00:46:44,580 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping all jobs
2016-05-18 00:46:44,581 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2016-05-18 00:46:44,581 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-450/first-nondete...] getDagStatus returned null
2016-05-18 00:46:45,322 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:49,681 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:51,733 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:51,853 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:51,952 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,026 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,167 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,315 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,416 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,597 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:52,744 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] submitted tez dag to app master: application_1463532326614_0008, with dag id: dag_1463532326614_0008_1
2016-05-18 00:46:52,746 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] stopped all jobs
2016-05-18 00:46:52,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-450/first-nondete...] completed in: 00:00.425
2016-05-18 00:46:52,785 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] stopped all flows
2016-05-18 00:46:52,785 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutting down flow executor
2016-05-18 00:46:52,785 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2016-05-18 00:46:52,786 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-450/first-nondete...] shutdown complete
2016-05-18 00:46:52,824 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:46:52,825 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:46:52,863 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-05-18 00:46:52,888 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 00:46:52,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:52,889 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:46:52,890 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:46:52,917 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting
2016-05-18 00:46:52,918 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] parallel execution of flows is enabled: false
2016-05-18 00:46:52,918 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] executing total flows: 1
2016-05-18 00:46:52,918 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-18 00:46:52,919 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2016-05-18 00:46:52,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] at least one sink is marked for delete
2016-05-18 00:46:52,919 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:46:52,922 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:55357/user/teamcity/.staging/2035ACA9CFE64592B1E0E9378913CBD7/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:46:52,946 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting
2016-05-18 00:46:52,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:46:52,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic"]
2016-05-18 00:46:52,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] parallel execution of steps is enabled: true
2016-05-18 00:46:52,947 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] executing total steps: 1
2016-05-18 00:46:52,948 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] allocating management threads: 1
2016-05-18 00:46:52,949 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:52,965 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] tez session mode enabled: false
2016-05-18 00:46:52,967 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:46:53,049 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:46:53,148 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0009
2016-05-18 00:46:53,149 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:46:53,162 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/2035ACA9CFE64592B1E0E9378913CBD7/E5E465C58F3A4BD68EF4B63DE806B92C/.tez/application_1463532326614_0009 doesn't exist and is created
2016-05-18 00:46:53,214 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:53,215 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0009
2016-05-18 00:46:53,263 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0009, dagName=[2035ACA9CFE64592B1E0E9378913CBD7/E5E465C58F3A4BD68EF4B63DE806B92C] race-500/first-nondeterministic/(1/1) ...00/first-nondeterministic
2016-05-18 00:46:53,269 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0009/
2016-05-18 00:46:53,417 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping all flows
2016-05-18 00:46:53,418 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2016-05-18 00:46:53,418 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping all jobs
2016-05-18 00:46:53,419 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2016-05-18 00:46:53,419 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [race-500/first-nondete...] getDagStatus returned null
2016-05-18 00:46:54,150 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:56,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0007_01_000002 is : 143
2016-05-18 00:46:56,933 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:57,256 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:57,860 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532326614_0007_01_000002
2016-05-18 00:46:58,975 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:59,064 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:46:59,140 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0008_01_000002 is : 143
2016-05-18 00:47:04,088 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,098 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,261 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,402 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,495 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,642 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] submitted tez dag to app master: application_1463532326614_0009, with dag id: dag_1463532326614_0009_1
2016-05-18 00:47:04,645 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] stopped all jobs
2016-05-18 00:47:04,714 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:04,723 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] stopped all flows
2016-05-18 00:47:04,723 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [race-500/first-nondete...] completed in: 00:00.472
2016-05-18 00:47:04,724 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2016-05-18 00:47:04,724 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutting down flow executor
2016-05-18 00:47:04,724 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [race-500/first-nondete...] shutdown complete
2016-05-18 00:47:04,724 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/parallelcascadeplatform/testCascadeRaceCondition/race-0/first-nondeterministic
2016-05-18 00:47:04,726 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/parallelcascadeplatform/testCascadeRaceCondition/race-250/first-nondeterministic
2016-05-18 00:47:04,734 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/parallelcascadeplatform/testCascadeRaceCondition/race-350/first-nondeterministic
2016-05-18 00:47:04,740 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/parallelcascadeplatform/testCascadeRaceCondition/race-50/first-nondeterministic
2016-05-18 00:47:04,741 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/parallelcascadeplatform/testCascadeRaceCondition/race-500/first-nondeterministic
2016-05-18 00:47:04,745 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/parallelcascadeplatform/testCascadeRaceCondition/race-100/first-nondeterministic
2016-05-18 00:47:04,751 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/parallelcascadeplatform/testCascadeRaceCondition/race-400/first-nondeterministic
2016-05-18 00:47:04,757 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/parallelcascadeplatform/testCascadeRaceCondition/race-300/first-nondeterministic
2016-05-18 00:47:04,763 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/parallelcascadeplatform/testCascadeRaceCondition/race-150/first-nondeterministic
2016-05-18 00:47:04,769 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/parallelcascadeplatform/testCascadeRaceCondition/race-450/first-nondeterministic
2016-05-18 00:47:04,775 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/parallelcascadeplatform/testCascadeRaceCondition/race-200/first-nondeterministic
2016-05-18 00:47:04,828 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:47:04,829 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:47:04,872 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.011
2016-05-18 00:47:04,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-18 00:47:04,884 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:04,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:04,885 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:47:04,936 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:47:04,937 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:47:04,976 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-05-18 00:47:04,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-18 00:47:04,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:04,992 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:04,993 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:47:05,046 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:47:05,047 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:47:05,083 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.010
2016-05-18 00:47:05,096 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 00:47:05,097 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:05,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:05,098 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:47:05,163 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:47:05,164 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:47:05,205 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.012
2016-05-18 00:47:05,226 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 00:47:05,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:05,227 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 00:47:05,228 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:47:05,289 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 00:47:05,290 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:47:05,361 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-05-18 00:47:05,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-05-18 00:47:05,373 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-05-18 00:47:05,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-05-18 00:47:05,374 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-18 00:47:05,526 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting
2016-05-18 00:47:05,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] parallel execution of flows is enabled: true
2016-05-18 00:47:05,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] executing total flows: 5
2016-05-18 00:47:05,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] allocating management threads: 5
2016-05-18 00:47:05,528 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first2
2016-05-18 00:47:05,529 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: first1
2016-05-18 00:47:05,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] at least one sink is marked for delete
2016-05-18 00:47:05,530 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] at least one sink is marked for delete
2016-05-18 00:47:05,530 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:47:05,531 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:47:05,533 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:55357/user/teamcity/.staging/4AB014CB3E2C4345AE8A6B6BEEB2E44C/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:47:05,534 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:55357/user/teamcity/.staging/2CFE90D0E96C40A8A6109A9B16729846/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:47:05,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting
2016-05-18 00:47:05,572 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:47:05,573 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-05-18 00:47:05,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] parallel execution of steps is enabled: true
2016-05-18 00:47:05,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] executing total steps: 1
2016-05-18 00:47:05,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] allocating management threads: 1
2016-05-18 00:47:05,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting
2016-05-18 00:47:05,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] source: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/classes/test/data/ips.20.txt"]
2016-05-18 00:47:05,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-05-18 00:47:05,575 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] starting step: (1/1) ...atform/testCascade/first2
2016-05-18 00:47:05,576 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] parallel execution of steps is enabled: true
2016-05-18 00:47:05,576 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] executing total steps: 1
2016-05-18 00:47:05,576 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] allocating management threads: 1
2016-05-18 00:47:05,577 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] starting step: (1/1) ...atform/testCascade/first1
2016-05-18 00:47:05,603 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] tez session mode enabled: false
2016-05-18 00:47:05,605 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] tez session mode enabled: false
2016-05-18 00:47:05,605 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:47:05,607 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:47:05,684 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:47:05,691 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:47:05,750 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0010
2016-05-18 00:47:05,750 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:47:05,764 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/4AB014CB3E2C4345AE8A6B6BEEB2E44C/C0D4ACD0DEA44C16B1AF09C0E900A298/.tez/application_1463532326614_0010 doesn't exist and is created
2016-05-18 00:47:05,764 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0011
2016-05-18 00:47:05,764 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:47:05,780 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/2CFE90D0E96C40A8A6109A9B16729846/AC2CB01B0758451FB07A660E48705D4E/.tez/application_1463532326614_0011 doesn't exist and is created
2016-05-18 00:47:05,852 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:05,853 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0010
2016-05-18 00:47:05,868 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:05,870 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0011
2016-05-18 00:47:05,937 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0010, dagName=[4AB014CB3E2C4345AE8A6B6BEEB2E44C/C0D4ACD0DEA44C16B1AF09C0E900A298] first2/(1/1) ...atform/testCascade/first2
2016-05-18 00:47:05,947 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0011, dagName=[2CFE90D0E96C40A8A6109A9B16729846/AC2CB01B0758451FB07A660E48705D4E] first1/(1/1) ...atform/testCascade/first1
2016-05-18 00:47:05,952 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0011/
2016-05-18 00:47:06,144 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0010/
2016-05-18 00:47:06,265 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:08,422 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:10,740 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:10,806 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:10,893 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,299 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,432 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,597 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,693 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,921 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:13,937 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] submitted tez dag to app master: application_1463532326614_0010, with dag id: dag_1463532326614_0010_1
2016-05-18 00:47:15,462 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:15,845 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0009_01_000002 is : 143
2016-05-18 00:47:15,886 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:17,659 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:19,636 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:19,651 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/parallelcascadeplatform/testCascade/first2/_temporary
2016-05-18 00:47:19,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first2] completed in: 00:14.076, using cpu time: 00:03.200
2016-05-18 00:47:19,654 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first2
2016-05-18 00:47:19,654 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second2
2016-05-18 00:47:19,654 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] at least one sink is marked for delete
2016-05-18 00:47:19,655 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:47:19,657 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:55357/user/teamcity/.staging/418D025979E64D8E8DA5CC02B0D3363B/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:47:19,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting
2016-05-18 00:47:19,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first2"]
2016-05-18 00:47:19,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-05-18 00:47:19,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] parallel execution of steps is enabled: true
2016-05-18 00:47:19,700 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] executing total steps: 1
2016-05-18 00:47:19,701 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] allocating management threads: 1
2016-05-18 00:47:19,702 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] starting step: (1/1) ...tform/testCascade/second2
2016-05-18 00:47:19,724 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] tez session mode enabled: false
2016-05-18 00:47:19,727 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:47:19,736 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:19,882 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:47:19,954 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0012
2016-05-18 00:47:19,955 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:47:19,976 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/418D025979E64D8E8DA5CC02B0D3363B/F1A4D933D3E54D709299CFCC0694C4C4/.tez/application_1463532326614_0012 doesn't exist and is created
2016-05-18 00:47:20,029 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:20,030 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0012
2016-05-18 00:47:20,086 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0012, dagName=[418D025979E64D8E8DA5CC02B0D3363B/F1A4D933D3E54D709299CFCC0694C4C4] second2/(1/1) ...tform/testCascade/second2
2016-05-18 00:47:20,092 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0012/
2016-05-18 00:47:23,828 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:23,964 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:24,111 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:24,188 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:24,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] submitted tez dag to app master: application_1463532326614_0011, with dag id: dag_1463532326614_0011_1
2016-05-18 00:47:24,408 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:24,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0010_01_000002 is : 143
2016-05-18 00:47:24,710 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:26,055 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:30,308 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:32,858 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:32,899 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/parallelcascadeplatform/testCascade/first1/_temporary
2016-05-18 00:47:32,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [first1] completed in: 00:27.324, using cpu time: 00:03.470
2016-05-18 00:47:32,902 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: first1
2016-05-18 00:47:32,902 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: second1
2016-05-18 00:47:32,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] at least one sink is marked for delete
2016-05-18 00:47:32,903 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:47:32,905 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:55357/user/teamcity/.staging/D0955D73A34C43D9829E9FCA554B5CEB/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:47:32,939 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:32,939 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting
2016-05-18 00:47:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/first1"]
2016-05-18 00:47:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-05-18 00:47:32,940 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] parallel execution of steps is enabled: true
2016-05-18 00:47:32,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] executing total steps: 1
2016-05-18 00:47:32,942 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] allocating management threads: 1
2016-05-18 00:47:32,944 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] starting step: (1/1) ...tform/testCascade/second1
2016-05-18 00:47:32,964 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] tez session mode enabled: false
2016-05-18 00:47:32,968 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:47:33,058 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:33,132 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:47:33,230 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0013
2016-05-18 00:47:33,230 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:47:33,248 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/D0955D73A34C43D9829E9FCA554B5CEB/FAB5DB7C18E442D392147B18DC76CAAA/.tez/application_1463532326614_0013 doesn't exist and is created
2016-05-18 00:47:33,316 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:33,317 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0013
2016-05-18 00:47:33,379 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0013, dagName=[D0955D73A34C43D9829E9FCA554B5CEB/FAB5DB7C18E442D392147B18DC76CAAA] second1/(1/1) ...tform/testCascade/second1
2016-05-18 00:47:33,385 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0013/
2016-05-18 00:47:33,763 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:33,898 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:34,075 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:34,146 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:34,369 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:34,396 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] submitted tez dag to app master: application_1463532326614_0012, with dag id: dag_1463532326614_0012_1
2016-05-18 00:47:35,934 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:37,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0011_01_000002 is : 143
2016-05-18 00:47:37,971 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:38,818 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1463532326614_0011_01_000001
2016-05-18 00:47:39,188 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:41,128 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:41,157 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/parallelcascadeplatform/testCascade/second2/_temporary
2016-05-18 00:47:41,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second2] completed in: 00:21.458, using cpu time: 00:03.160
2016-05-18 00:47:41,160 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second2
2016-05-18 00:47:41,198 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:41,276 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:45,608 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:45,755 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:45,920 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:46,009 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:46,221 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] submitted tez dag to app master: application_1463532326614_0013, with dag id: dag_1463532326614_0013_1
2016-05-18 00:47:46,241 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0012_01_000002 is : 143
2016-05-18 00:47:46,288 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:46,308 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:47,768 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:49,634 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:51,396 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:51,425 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/parallelcascadeplatform/testCascade/second1/_temporary
2016-05-18 00:47:51,427 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [second1] completed in: 00:18.485, using cpu time: 00:03.190
2016-05-18 00:47:51,428 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: second1
2016-05-18 00:47:51,428 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] starting flow: lhs*rhs
2016-05-18 00:47:51,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] at least one sink is marked for delete
2016-05-18 00:47:51,428 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2016-05-18 00:47:51,430 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:55357/user/teamcity/.staging/38E1B5082294467998EDF737827FE7DF/cascading-hadoop2-tez-3.1.0.jar
2016-05-18 00:47:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting
2016-05-18 00:47:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second2"]
2016-05-18 00:47:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/second1"]
2016-05-18 00:47:51,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line' | long, String]->[ALL]]"]["/opt/buildAgent-8.0.3/work/2f4c45215847827d/apache-2.6.x-tez-0.8.x/build/test/output/hadoop2-tez/parallelcascadeplatform/testCascade/third"]
2016-05-18 00:47:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] parallel execution of steps is enabled: true
2016-05-18 00:47:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] executing total steps: 1
2016-05-18 00:47:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] allocating management threads: 1
2016-05-18 00:47:51,454 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] starting step: (1/1) ...latform/testCascade/third
2016-05-18 00:47:51,469 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] tez session mode enabled: false
2016-05-18 00:47:51,471 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:47:51,479 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:51,547 INFO client.TezClient (TezClient.java:start(354)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-05-18 00:47:51,611 INFO client.TezClient (TezClient.java:submitDAGApplication(861)) - Submitting DAG application with id: application_1463532326614_0014
2016-05-18 00:47:51,611 INFO client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(176)) - Using tez.lib.uris value from configuration: hdfs://localhost:55357/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-05-18 00:47:51,623 INFO client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(122)) - Tez system stage directory hdfs://localhost:55357/user/teamcity/.staging/38E1B5082294467998EDF737827FE7DF/B99B2159DCE14CE4919A790CEE8D1FBB/.tez/application_1463532326614_0014 doesn't exist and is created
2016-05-18 00:47:51,664 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:51,665 INFO acls.ATSHistoryACLPolicyManager (ATSHistoryACLPolicyManager.java:createSessionDomain(166)) - Created Timeline Domain for History ACLs, domainId=Tez_ATS_application_1463532326614_0014
2016-05-18 00:47:51,713 INFO client.TezClient (TezClient.java:submitDAGApplication(887)) - Submitting DAG to YARN, applicationId=application_1463532326614_0014, dagName=[38E1B5082294467998EDF737827FE7DF/B99B2159DCE14CE4919A790CEE8D1FBB] lhs*rhs/(1/1) ...latform/testCascade/third
2016-05-18 00:47:51,718 INFO client.TezClient (TezClient.java:submitDAGApplication(894)) - The url to track the Tez AM: http://ip-10-123-148-208:40710/proxy/application_1463532326614_0014/
2016-05-18 00:47:56,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1463532326614_0013_01_000002 is : 143
2016-05-18 00:47:56,514 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:57,695 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:57,808 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,021 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,114 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,238 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,312 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,374 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,443 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:47:58,465 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] submitted tez dag to app master: application_1463532326614_0014, with dag id: dag_1463532326614_0014_1
2016-05-18 00:47:59,942 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:03,831 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:04,039 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:06,498 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:06,583 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:06,682 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:07,154 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:07,158 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/parallelcascadeplatform/testCascade/third/_temporary
2016-05-18 00:48:07,160 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [lhs*rhs] completed in: 00:15.705, using cpu time: 00:07.150
2016-05-18 00:48:07,160 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first1+second1+first2+...] completed flow: lhs*rhs
2016-05-18 00:48:07,217 WARN server.AuthenticationFilter (AuthenticationFilter.java:doFilter(499)) - AuthenticationToken ignored: org.apache.hadoop.security.authentication.util.SignerException: Invalid signature
2016-05-18 00:48:07,220 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/parallelcascadeplatform/testCascade/second2
2016-05-18 00:48:07,227 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/parallelcascadeplatform/testCascade/first2
2016-05-18 00:48:07,234 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/parallelcascadeplatform/testCascade/second1
2016-05-18 00:48:07,241 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/parallelcascadeplatform/testCascade/first1
2016-05-18 00:48:07,248 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/parallelcascadeplatform/testCascade/third