Class cascading.FieldedPipesPlatformTest

29

tests

0

failures

0

ignored

7m48.52s

duration

100%

successful

Tests

Test Duration Result
testChainEndingWithEach 15.654s passed
testConcatenation 14.809s passed
testCopy 12.481s passed
testFilter 14.097s passed
testFilterAll 19.835s passed
testFilterComplex 30.262s passed
testGeneratorAggregator 16.076s passed
testGroupByInsensitive 18.538s passed
testGroupGroup 20.020s passed
testLogicFilter 13.803s passed
testNoGroup 13.568s passed
testNone 14.928s passed
testReplace 12.612s passed
testSameSourceMergeThreeChainGroup 15.728s passed
testSimpleChain 15.502s passed
testSimpleGroup 15.176s passed
testSimpleMerge 17.200s passed
testSimpleMergeThree 18.175s passed
testSplit 13.742s passed
testSplitComplex 15.461s passed
testSplitMultiple 17.317s passed
testSplitNonSafe 13.377s passed
testSplitOut 21.206s passed
testSplitSameSourceMerged 16.050s passed
testSplitSameSourceMergedSameName 17.535s passed
testSwap 15.497s passed
testUnGroup 11.885s passed
testUnGroupAnon 14.092s passed
testUnGroupBySize 13.896s passed

Standard output

2016-01-14 16:48:10,022 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 16:48:10,044 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-tez
2016-01-14 16:48:10,074 INFO  tez.Hadoop2TezPlatform (Hadoop2TezPlatform.java:setUp(164)) - using cluster
2016-01-14 16:48:10,735 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2016-01-14 16:48:11,657 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2016-01-14 16:48:12,263 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:15,224 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceInit(109)) - Using Tez AppJar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.6.2/7cfbec38ae59bd135b5606c0b42dce12b41c076c/tez-dag-0.6.2.jar
2016-01-14 16:48:15,462 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceInit(121)) - Set TEZ-LIB-URI to: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:48:15,468 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceInit(152)) - mkdir: hdfs://localhost:39396/apps_staging_dir
2016-01-14 16:48:15,831 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 16:48:15,916 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 16:48:15,962 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 16:48:16,008 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2016-01-14 16:48:16,013 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceStart(186)) - Starting MiniTezCluster
2016-01-14 16:48:16,250 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:16,255 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:16,256 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:21,650 INFO  test.MiniTezCluster (MiniTezCluster.java:serviceStart(205)) - Setting yarn-site.xml via YARN-APP-CP at: /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/target/cascading.platform.tez.Hadoop2TezPlatform,/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/resources/test:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/main:/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/resources/main:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.0.4/f8041cf548c12cc6e997a63a67562fcf5b2e237/cascading-core-3.0.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-platform/3.0.4/2c7c4ae0a2ac3b7e296414816e065fb601e9be39/cascading-platform-3.0.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/4f45ecd85538b8cc8c352ccd4f33c52c1776a545/cascading-hadoop2-tez-3.0.4-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-core/2.5.2/a7168fb50e32ee16e926e28ba0459580c36b2548/hadoop-mapreduce-client-core-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.5.2/d4a60ca549b1f9064578a4ac0a2340624e2440bd/hadoop-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-minicluster/2.5.2/b7ec5d497be231060f492203a205e8cbdccb6b70/hadoop-minicluster-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.5/6b262da268f8ad9eff941b25503a9198f0a0ac93/slf4j-api-1.7.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-tests/0.6.2/e6c7cbbf7f067cea6a8f8c5bea595536e141dd70/tez-tests-0.6.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-api/0.6.2/7be44271b408cb2a59181fc1c3d45d0bb2e6bb93/tez-api-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-dag/0.6.2/7cfbec38ae59bd135b5606c0b42dce12b41c076c/tez-dag-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-yarn-timeline-history/0.6.2/4765a7b7c177208970def6b9640c1366a61c264c/tez-yarn-timeline-history-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/junit/junit/4.12/2973d150c0dc1fefe998f834810d68f278ea58ec/junit-4.12.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/riffle/riffle/1.0.0/d991264d10c1e80f8588d2480e3f6e536e30fcb2/riffle-1.0.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.jgrapht/jgrapht-core/0.9.1/872b4fd3a6d8a4f0bdfb0f6e26c4499e752ce39/jgrapht-core-0.9.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.janino/janino/2.7.6/37fde5de7edd5d7ebe075f03f4c083df2ac73dd8/janino-2.7.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-core/3.0.4/db7694f29f171efa077bb0192f3c3039f7514807/cascading-core-3.0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-common/2.5.2/8bc52cc38b68820e9fc4831e3942802f6034404e/hadoop-yarn-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.protobuf/protobuf-java/2.5.0/a10732c76bfacdbd633a7eb0f7968b1059a65dfa/protobuf-java-2.5.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.avro/avro/1.7.4/416e7030879814f52845b97f04bb50ecd1cef372/avro-1.7.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-annotations/2.5.2/7bf4cdb8c35cf4dd761726c02b7677a169162f0a/hadoop-annotations-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.inject.extensions/guice-servlet/3.0/610cde0e8da5a8b7d8efb8f0b8987466ffebaaf9/guice-servlet-3.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/11.0.2/35a3c69e19d72743cac83778aecbee68680f63eb/guava-11.0.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-cli/commons-cli/1.2/2bf96b7aa8b611c177d329452af1dc933e14501c/commons-cli-1.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-math3/3.1.1/6719d757a98ff24a83d9d727bef9cec83f59b6e1/commons-math3-3.1.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/xmlenc/xmlenc/0.52/d82554efbe65906d83b3d97bd7509289e9db561a/xmlenc-0.52.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-httpclient/commons-httpclient/3.1/964cd74171f427720480efdec40a7c7f6e58426a/commons-httpclient-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-io/commons-io/2.4/b1b6ea3b7e4aa4f492509a4952029cd8e48019ad/commons-io-2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-net/commons-net/3.1/2298164a7c2484406f2aa5ac85b205d39019896f/commons-net-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-collections/commons-collections/3.2.1/761ea405b9b37ced573d2df0d1e3a4e0f9edc668/commons-collections-3.2.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.servlet/servlet-api/2.5/5959582d97d8b61f4d154ca9e495aafd16726e34/servlet-api-2.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty/6.1.26/2f546e289fddd5b1fab1d4199fbb6e9ef43ee4b0/jetty-6.1.26.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/jetty-util/6.1.26/e5642fe0399814e1687d55a3862aa5a3417226a9/jetty-util-6.1.26.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-core/1.9/8341846f18187013bb9e27e46b7ee00a6395daf4/jersey-core-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-json/1.9/1aa73e1896bcc7013fed247157d7f676226eb432/jersey-json-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-server/1.9/3a6ea7cc5e15c824953f9f3ece2201b634d90d18/jersey-server-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/tomcat/jasper-compiler/5.5.23/6d35bd7fb8c4fbc1f5401fb3678aa976d2e4c241/jasper-compiler-5.5.23.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/tomcat/jasper-runtime/5.5.23/96ca5528a93ab47b001476b74320c644beb89dde/jasper-runtime-5.5.23.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.servlet.jsp/jsp-api/2.1/63f943103f250ef1f3a4d5e94d145a0f961f5316/jsp-api-2.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-el/commons-el/1.0/1df2c042b3f2de0124750241ac6c886dbfa2cc2c/commons-el-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.1.3/f6f66e966c70a83ffbdb6f17a0919eaf7c8aca7f/commons-logging-1.1.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/net.java.dev.jets3t/jets3t/0.9.0/792bc96ee7e57b89f472aa0cb5a31015b9f59c96/jets3t-0.9.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-lang/commons-lang/2.6/ce1edb914c94ebc388f086c6827e8bdeec71ac2/commons-lang-2.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-configuration/commons-configuration/1.6/32cadde23955d7681b0d94a2715846d20b425235/commons-configuration-1.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-core-asl/1.9.13/3c304d70f42f832e0a86d45bd437f692129299a4/jackson-core-asl-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-mapper-asl/1.9.13/1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7/jackson-mapper-asl-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-auth/2.5.2/e637ea131afd368853034649c48b36d032aead52/hadoop-auth-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.jcraft/jsch/0.1.42/a86104b0f2e0c0bab5b0df836065823a99b5e334/jsch-0.1.42.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.6/1b2502e29da1ebaade2357cd1de35a855fa3755/zookeeper-3.4.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-compress/1.4.1/b02e84a993d88568417536240e970c4b809126fd/commons-compress-1.4.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-common/2.5.2/9449a553c364a5b13be1789e1921915dde6e444b/hadoop-common-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.5.2/eb891cf7dd6533281c13be4f31b641561908d686/hadoop-hdfs-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-hdfs/2.5.2/7c555a887341e8abd95cec5815bb8d920db74969/hadoop-hdfs-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-tests/2.5.2/d4146517ed4f66c8d05261f2a52f36149414f504/hadoop-yarn-server-tests-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.5.2/b0e0f83051d9930577ced46b9d67bade0df33fec/hadoop-mapreduce-client-jobclient-2.5.2-tests.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-jobclient/2.5.2/a4dc84d6dfab278f58d729073ae9d93ac1e7b2f9/hadoop-mapreduce-client-jobclient-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-app/2.5.2/345951a8ac3de5bbdf6cc81029e74e2c64e862af/hadoop-mapreduce-client-app-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-api/2.5.2/ed56ef51f79bec95a258681d38a61dbc1713724e/hadoop-yarn-api-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-hs/2.5.2/154271ac4333b0372097d1b46b48efd9bd50516c/hadoop-mapreduce-client-hs-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-library/0.6.2/51f93c866043ed03d16e9657c292858b752100ad/tez-runtime-library-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-mapreduce/0.6.2/dc9fc549fb8023221647d410b3e17b751a1b2c03/tez-mapreduce-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-examples/0.6.2/cd9c5d801f5ffee25bc6e2f0a271e32c5c95c65/tez-examples-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-client/2.5.2/f62818f180f489d18607474ddeb7f0072c00f87d/hadoop-yarn-client-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-common/2.5.2/4c643ab26741daf6d570bab6008b95c8b2562a8f/hadoop-mapreduce-client-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-collections4/4.0/da217367fd25e88df52ba79e47658d4cf928b0d1/commons-collections4-4.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey/jersey-client/1.9/d3c4b2b5f89db32c96ceddcb863684821910a7bb/jersey-client-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-common/0.6.2/2b6e194f37e7a9931e8f2f732fd167c20395adb5/tez-common-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.tez/tez-runtime-internals/0.6.2/c03a09ad12e31ea93c2a2131fbf96f0993875e24/tez-runtime-internals-0.6.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-web-proxy/2.5.2/b0030cb1a2abb5eaeac9850ce0c598b141186328/hadoop-yarn-server-web-proxy-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jettison/jettison/1.3.4/3c08d8f699432e23023080cdc8b4073132473dc8/jettison-1.3.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.janino/commons-compiler/2.7.6/b71e76d942b33dfa26e4e3047ff2a774d1f917b4/commons-compiler-2.7.6.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.xml.bind/jaxb-api/2.2.2/aeb3021ca93dde265796d82015beecdcff95bf09/jaxb-api-2.2.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-jaxrs/1.9.13/534d72d2b9d6199dd531dfb27083dd4844082bba/jackson-jaxrs-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-xc/1.9.13/e3480072bc95c202476ffa1de99ff7ee9149f29c/jackson-xc-1.9.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.inject/guice/3.0/9d84f15fe35e2c716a02979fb62f50a29f38aefa/guice-3.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.jersey.contribs/jersey-guice/1.9/5963c28c47df7e5d6ad34cec80c071c368777f7b/jersey-guice-1.9.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.3/4a85963a752c0a2f715c3924bfc686865e7e1bc6/paranamer-2.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.0.4.1/f88b89a5a21a466aeb0ecf0c063605bd584b4947/snappy-java-1.0.4.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.mortbay.jetty/servlet-api/2.5-20081211/22bff70037e1e6fa7e6413149489552ee2064702/servlet-api-2.5-20081211.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/2.2.3-1/56baae106392040a45a06d4a41099173425da1e6/jaxb-impl-2.2.3-1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/asm/asm/3.1/c157def142714c544bdea2e6144645702adf7097/asm-3.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.jamesmurty.utils/java-xmlbuilder/0.4/ac5962e48cdee3a0a6e1f8e00fcb594747ac5aaf/java-xmlbuilder-0.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-digester/commons-digester/1.8/dc6a73fdbd1fa3f0944e8497c6c872fa21dca37e/commons-digester-1.8.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils-core/1.8.0/175dc721f87e4bc5cc0573f990e28c3cf9117508/commons-beanutils-core-1.8.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-kerberos-codec/2.0.0-M15/1c16e4e477183641c5f0dd5cdecd27ec331bacb5/apacheds-kerberos-codec-2.0.0-M15.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.tukaani/xz/1.0/ecff5cb8b1189514c9d1d8d68eb77ac372e000c9/xz-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-daemon/commons-daemon/1.0.13/750856a1fdb3ddf721ccf73c3518e4211cffc3a3/commons-daemon-1.0.13.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-common/2.5.2/f2203b3e8afeb600b899bfd944e1554adf55902/hadoop-yarn-server-common-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-nodemanager/2.5.2/36f02e92a13ccfd489a0e24df8ad5aa7f14ebee4/hadoop-yarn-server-nodemanager-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-resourcemanager/2.5.2/874925a5e8c6221bd11526b5b28762c6cfad1ea6/hadoop-yarn-server-resourcemanager-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-mapreduce-client-shuffle/2.5.2/1c2c8ada2300a9fca6967f1de0300e1b5d86a4a/hadoop-mapreduce-client-shuffle-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.xml.stream/stax-api/1.0-2/d6337b0de8b25e53e81b922352fbea9f9f57ba0b/stax-api-1.0-2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1/e6cb541461c2834bdea3eb920f1884d1eb508b50/activation-1.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/javax.inject/javax.inject/1/6975da39a7040257bd51d21a231b76c915872d38/javax.inject-1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/aopalliance/aopalliance/1.0/235ba8b489512805ac13a8f9ea77a1ca5ebe3e8/aopalliance-1.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.sonatype.sisu.inject/cglib/2.2.1-v20090111/7ce5e983fd0e6c78346f4c9cbfa39d83049dda2/cglib-2.2.1-v20090111.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils/1.7.0/5675fd96b29656504b86029551973d60fb41339b/commons-beanutils-1.7.0.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.server/apacheds-i18n/2.0.0-M15/71c61c84683152ec2a6a65f3f96fe534e304fa22/apacheds-i18n-2.0.0-M15.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-asn1-api/1.0.0-M20/5e6486ffa3125ba44dc410ead166e1d6ba8ac76d/api-asn1-api-1.0.0-M20.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.directory.api/api-util/1.0.0-M20/a871abf060b3cf83fc6dc4d7e3d151fce50ac3cb/api-util-1.0.0-M20.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.fusesource.leveldbjni/leveldbjni-all/1.8/707350a2eeb1fa2ed77a32ddb3893ed308e941db/leveldbjni-all-1.8.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice/2.5.2/e31679646334eda7ab10b73ef02d97c082fd5db4/hadoop-yarn-server-applicationhistoryservice-2.5.2.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/jline/jline/0.9.94/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/2.0.3/5871fb60dc68d67da54a663c3fd636a10a532948/jsr305-2.0.3.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/stax/stax-api/1.0.1/49c100caf72d658aca8e58bd74a4ba90fa2b0d70/stax-api-1.0.1.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.2.5/666e26e76f2e87d84e4f16acb546481ae1b8e9a6/httpclient-4.2.5.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/io.netty/netty/3.7.0.Final/7a8c35599c68c0bf383df74469aa3e03d9aca87/netty-3.7.0.Final.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.2.4/3b7f38df6de5dd8b500e602ae8c2dd5ee446f883/httpcore-4.2.4.jar:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.6/b7f0fc8f61ecadeb3695f0b9464755eee44374d4/commons-codec-1.6.jar
2016-01-14 16:48:21,950 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:22,192 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:22,193 WARN  server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2016-01-14 16:48:22,246 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 16:48:22,365 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:48:22,365 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:22,433 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: A2FBEEA7E089486C94E905F01E79B9F3
2016-01-14 16:48:22,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.097
2016-01-14 16:48:22,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.125
2016-01-14 16:48:22,630 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:22,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:22,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:48:23,103 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/D1C6E7F8149946B98863AD5BB1B1EB3C/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:23,166 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 16:48:23,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:48:23,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:48:23,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2016-01-14 16:48:23,168 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:48:23,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:48:23,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:48:23,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2016-01-14 16:48:23,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:48:23,203 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:48:23,420 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:48:23,453 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0001
2016-01-14 16:48:23,454 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:48:23,473 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/D1C6E7F8149946B98863AD5BB1B1EB3C/E016406C32ED46A6BB43F653945AF39F/.tez/application_1452790096014_0001 doesn't exist and is created
2016-01-14 16:48:23,668 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0001, dagName=[D1C6E7F8149946B98863AD5BB1B1EB3C/E016406C32ED46A6BB43F653945AF39F] test/(1/1) ...lterComplex/filtercomplex
2016-01-14 16:48:23,984 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0001/
2016-01-14 16:48:24,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0001, with dag id: dag_1452790096014_0001_1
2016-01-14 16:48:40,217 INFO  client.TimelineReaderFactory (TimelineReaderFactory.java:tokenDelegationSupported(381)) - Could not find class required for token delegation, will fallback to pseudo auth
2016-01-14 16:48:40,251 INFO  counters.Limits (Limits.java:ensureInitialized(59)) - Counter limits initialized with parameters:  GROUP_NAME_MAX=128, MAX_GROUPS=500, COUNTER_NAME_MAX=64, MAX_COUNTERS=1200
2016-01-14 16:48:40,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:17.086, using cpu time: 00:04.560
2016-01-14 16:48:40,322 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testFilterComplex/filtercomplex
2016-01-14 16:48:40,370 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:48:40,370 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:40,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-01-14 16:48:40,492 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.068
2016-01-14 16:48:40,493 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:40,494 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:40,494 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:48:40,616 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/72CE5286DC84490C8C9A0FC9B3089A12/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:40,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:48:40,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:48:40,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSimpleChain/simplechain"]
2016-01-14 16:48:40,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:48:40,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:48:40,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:48:40,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2016-01-14 16:48:40,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:48:40,673 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:48:40,770 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:48:40,773 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0002
2016-01-14 16:48:40,773 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:48:40,790 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/72CE5286DC84490C8C9A0FC9B3089A12/B67ABB2A4A0A4ACAAD438A4F0B270C0F/.tez/application_1452790096014_0002 doesn't exist and is created
2016-01-14 16:48:40,861 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0002, dagName=[72CE5286DC84490C8C9A0FC9B3089A12/B67ABB2A4A0A4ACAAD438A4F0B270C0F] test/(1/1) ...stSimpleChain/simplechain
2016-01-14 16:48:40,866 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0002/
2016-01-14 16:48:41,002 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0001_01_000004
2016-01-14 16:48:41,002 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0001_01_000003
2016-01-14 16:48:41,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0002, with dag id: dag_1452790096014_0002_1
2016-01-14 16:48:45,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0001_01_000002 is : 143
2016-01-14 16:48:46,004 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0001
2016-01-14 16:48:46,246 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0001_01_000002
2016-01-14 16:48:55,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:15.135, using cpu time: 00:03.940
2016-01-14 16:48:55,825 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSimpleChain/simplechain
2016-01-14 16:48:55,875 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:48:55,875 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:55,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 16:48:55,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-14 16:48:55,974 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:55,975 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:48:55,975 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:48:56,066 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/44F7B82591904D1CBA61BDD7C9C0C1E5/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:48:56,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:48:56,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:48:56,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSimpleGroup/simple"]
2016-01-14 16:48:56,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:48:56,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:48:56,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:48:56,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2016-01-14 16:48:56,123 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:48:56,127 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:48:56,221 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:48:56,222 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0003
2016-01-14 16:48:56,222 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:48:56,237 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/44F7B82591904D1CBA61BDD7C9C0C1E5/D3209ED69F72438F803B972DD73954B7/.tez/application_1452790096014_0003 doesn't exist and is created
2016-01-14 16:48:56,305 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0003, dagName=[44F7B82591904D1CBA61BDD7C9C0C1E5/D3209ED69F72438F803B972DD73954B7] test/(1/1) ...rm/testSimpleGroup/simple
2016-01-14 16:48:56,310 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0003/
2016-01-14 16:48:56,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0003, with dag id: dag_1452790096014_0003_1
2016-01-14 16:48:56,835 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0002_01_000003
2016-01-14 16:48:56,879 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0002_01_000004
2016-01-14 16:49:00,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0002_01_000002 is : 143
2016-01-14 16:49:10,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:14.832, using cpu time: 00:03.970
2016-01-14 16:49:11,002 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSimpleGroup/simple
2016-01-14 16:49:11,076 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:49:11,076 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:11,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-01-14 16:49:11,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.064
2016-01-14 16:49:11,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:49:11,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:49:11,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:49:11,277 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: B724969D66554391A15E41CD28987531,C44BF92A5C4E4E16B4B58AAE3C4064B5 and CFC0AEFF9E8E46CF90700D0AD3375811
2016-01-14 16:49:11,279 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/0FB0A9DA54264E5D813C9159AF5CBA31/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:11,301 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 16:49:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/upper.txt"]
2016-01-14 16:49:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower.txt"]
2016-01-14 16:49:11,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2016-01-14 16:49:11,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 16:49:11,303 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 16:49:11,304 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 16:49:11,305 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2016-01-14 16:49:11,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tez session mode enabled: false
2016-01-14 16:49:11,322 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:49:11,413 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:49:11,414 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0004
2016-01-14 16:49:11,414 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:49:11,425 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/0FB0A9DA54264E5D813C9159AF5CBA31/AE3C3A0377294F3EAE69138A58D4B354/.tez/application_1452790096014_0004 doesn't exist and is created
2016-01-14 16:49:11,500 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0004, dagName=[0FB0A9DA54264E5D813C9159AF5CBA31/AE3C3A0377294F3EAE69138A58D4B354] merge/(1/1) ...stSimpleMerge/simplemerge
2016-01-14 16:49:11,503 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0004/
2016-01-14 16:49:11,600 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted tez dag to app master: application_1452790096014_0004, with dag id: dag_1452790096014_0004_1
2016-01-14 16:49:11,813 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0003_01_000003
2016-01-14 16:49:11,884 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0003_01_000004
2016-01-14 16:49:15,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0003_01_000002 is : 143
2016-01-14 16:49:17,886 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0003
2016-01-14 16:49:28,130 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:16.828, using cpu time: 00:07.950
2016-01-14 16:49:28,202 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSimpleMerge/simplemerge
2016-01-14 16:49:28,344 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:49:28,344 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:28,390 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 16:49:28,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-01-14 16:49:28,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:49:28,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:49:28,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:49:28,534 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/99EA3A2515944E4989E00D9CD43F3E45/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:28,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:49:28,557 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:49:28,558 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2016-01-14 16:49:28,558 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:49:28,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:49:28,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:49:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2016-01-14 16:49:28,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:49:28,578 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:49:28,668 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:49:28,670 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0005
2016-01-14 16:49:28,670 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:49:28,681 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/99EA3A2515944E4989E00D9CD43F3E45/E6C0F44142FA41AAB6B0F97A2770C94A/.tez/application_1452790096014_0005 doesn't exist and is created
2016-01-14 16:49:28,757 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0005, dagName=[99EA3A2515944E4989E00D9CD43F3E45/E6C0F44142FA41AAB6B0F97A2770C94A] test/(1/1) ...nEndingWithEach/chaineach
2016-01-14 16:49:28,761 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0005/
2016-01-14 16:49:28,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0005, with dag id: dag_1452790096014_0005_1
2016-01-14 16:49:33,156 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0004_01_000003 is : 143
2016-01-14 16:49:33,188 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0004_01_000002 is : 143
2016-01-14 16:49:34,149 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0004_01_000002
2016-01-14 16:49:34,150 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0004_01_000003
2016-01-14 16:49:43,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:15.264, using cpu time: 00:04.170
2016-01-14 16:49:43,859 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testChainEndingWithEach/chaineach
2016-01-14 16:49:43,895 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:49:43,895 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:43,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 16:49:43,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 16:49:43,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:49:43,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:49:43,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:49:44,033 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/DA3206132AC14C5DB2B5CE9BD63231E0/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:49:44,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:49:44,060 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:49:44,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2016-01-14 16:49:44,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:49:44,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:49:44,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:49:44,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...gator/generatoraggregator
2016-01-14 16:49:44,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:49:44,102 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:49:44,197 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:49:44,198 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0006
2016-01-14 16:49:44,198 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:49:44,209 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/DA3206132AC14C5DB2B5CE9BD63231E0/F9E8AB42BB5F4E48ACCE560711FB18CA/.tez/application_1452790096014_0006 doesn't exist and is created
2016-01-14 16:49:44,262 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0006, dagName=[DA3206132AC14C5DB2B5CE9BD63231E0/F9E8AB42BB5F4E48ACCE560711FB18CA] test/(1/1) ...gator/generatoraggregator
2016-01-14 16:49:44,265 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0006/
2016-01-14 16:49:44,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0006, with dag id: dag_1452790096014_0006_1
2016-01-14 16:49:44,946 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0005_01_000003
2016-01-14 16:49:45,022 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0005_01_000004
2016-01-14 16:49:48,849 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0005_01_000002 is : 143
2016-01-14 16:49:49,833 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0005_01_000002
2016-01-14 16:49:50,025 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0005
2016-01-14 16:49:59,886 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:15.825, using cpu time: 00:03.880
2016-01-14 16:49:59,935 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2016-01-14 16:49:59,991 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:49:59,991 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:00,049 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 16:50:00,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 16:50:00,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:50:00,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:50:00,089 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:50:00,191 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: AAAE1B55AA82410C8715B879223F98F9,B5C62785E1E84FFF90C1B5C09BAB13F1,B158D76061AD4E32A332DD7671B5F69C and C0F852DD55414C508CE72925D6E3499D
2016-01-14 16:50:00,192 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/A64828986C994082B404021FA76A32FE/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:00,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2016-01-14 16:50:00,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/upper.txt"]
2016-01-14 16:50:00,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower.txt"]
2016-01-14 16:50:00,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower-offset.txt"]
2016-01-14 16:50:00,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextDelimited[['num', 'first']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2016-01-14 16:50:00,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2016-01-14 16:50:00,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2016-01-14 16:50:00,220 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2016-01-14 16:50:00,221 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2016-01-14 16:50:00,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tez session mode enabled: false
2016-01-14 16:50:00,245 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:50:00,356 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:50:00,357 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0007
2016-01-14 16:50:00,357 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:50:00,369 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/A64828986C994082B404021FA76A32FE/CF630F94C73E4C7CBDBE6C711866B057/.tez/application_1452790096014_0007 doesn't exist and is created
2016-01-14 16:50:00,431 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0007, dagName=[A64828986C994082B404021FA76A32FE/CF630F94C73E4C7CBDBE6C711866B057] merge/(1/1) ...rgeThree/simplemergethree
2016-01-14 16:50:00,436 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0007/
2016-01-14 16:50:00,528 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted tez dag to app master: application_1452790096014_0007, with dag id: dag_1452790096014_0007_1
2016-01-14 16:50:01,028 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0006_01_000003
2016-01-14 16:50:01,164 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0006_01_000004
2016-01-14 16:50:04,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0006_01_000002 is : 143
2016-01-14 16:50:05,908 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0006_01_000002
2016-01-14 16:50:06,166 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0006
2016-01-14 16:50:18,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:17.823, using cpu time: 00:14.570
2016-01-14 16:50:18,110 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2016-01-14 16:50:18,147 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:50:18,148 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:18,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 16:50:18,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 16:50:18,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:50:18,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:50:18,204 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:50:18,232 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/04B27DBF11264E3B840FE52C9E7751DD/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 16:50:18,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 1
2016-01-14 16:50:18,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 1
2016-01-14 16:50:18,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/1) ...plitNonSafe/nonsafesplit1
2016-01-14 16:50:18,270 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tez session mode enabled: false
2016-01-14 16:50:18,274 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:50:18,359 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:50:18,361 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0008
2016-01-14 16:50:18,362 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:50:18,372 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/04B27DBF11264E3B840FE52C9E7751DD/B3F94BBC316944EBA53D325C04A6D50A/.tez/application_1452790096014_0008 doesn't exist and is created
2016-01-14 16:50:18,429 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0008, dagName=[04B27DBF11264E3B840FE52C9E7751DD/B3F94BBC316944EBA53D325C04A6D50A] left+right/(1/1) ...plitNonSafe/nonsafesplit1
2016-01-14 16:50:18,432 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0008/
2016-01-14 16:50:18,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted tez dag to app master: application_1452790096014_0008, with dag id: dag_1452790096014_0008_1
2016-01-14 16:50:23,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0007_01_000003 is : 143
2016-01-14 16:50:23,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0007_01_000004 is : 143
2016-01-14 16:50:23,133 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0007_01_000002 is : 143
2016-01-14 16:50:31,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:13.173, using cpu time: 00:02.840
2016-01-14 16:50:31,487 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2016-01-14 16:50:31,492 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2016-01-14 16:50:31,521 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:50:31,521 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:31,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-01-14 16:50:31,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 16:50:31,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:50:31,582 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:50:31,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:50:31,720 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/DC33BF95498E432BBD701457D1A32016/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:31,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting
2016-01-14 16:50:31,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:50:31,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitOut/splitout2"]
2016-01-14 16:50:31,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitOut/splitout1"]
2016-01-14 16:50:31,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  parallel execution of steps is enabled: true
2016-01-14 16:50:31,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  executing total steps: 1
2016-01-14 16:50:31,744 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  allocating management threads: 1
2016-01-14 16:50:31,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (1/1) ...rm/testSplitOut/splitout2
2016-01-14 16:50:31,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tez session mode enabled: false
2016-01-14 16:50:31,762 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:50:31,847 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:50:31,848 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0009
2016-01-14 16:50:31,848 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:50:31,857 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/DC33BF95498E432BBD701457D1A32016/D6A7CD03718E410D9280ACFFEB613AF8/.tez/application_1452790096014_0009 doesn't exist and is created
2016-01-14 16:50:31,922 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0009, dagName=[DC33BF95498E432BBD701457D1A32016/D6A7CD03718E410D9280ACFFEB613AF8] output1+output2/(1/1) ...rm/testSplitOut/splitout2
2016-01-14 16:50:31,926 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0009/
2016-01-14 16:50:32,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted tez dag to app master: application_1452790096014_0009, with dag id: dag_1452790096014_0009_1
2016-01-14 16:50:36,460 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0008_01_000002 is : 143
2016-01-14 16:50:48,074 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0009_01_000005
2016-01-14 16:50:48,182 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0009_01_000006
2016-01-14 16:50:52,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0009_01_000002 is : 143
2016-01-14 16:50:52,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  completed in: 00:20.793, using cpu time: 00:10.690
2016-01-14 16:50:52,686 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitOut/splitout1
2016-01-14 16:50:52,695 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitOut/splitout2
2016-01-14 16:50:52,734 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:50:52,734 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:52,780 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 16:50:52,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 16:50:52,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:50:52,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:50:52,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:50:52,815 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/D216295C9D63443EADADCFA91D6923AF/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:50:52,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 16:50:52,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:50:52,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplit/split1"]
2016-01-14 16:50:52,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplit/split2"]
2016-01-14 16:50:52,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 16:50:52,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 1
2016-01-14 16:50:52,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 1
2016-01-14 16:50:52,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/1) ...platform/testSplit/split2
2016-01-14 16:50:52,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tez session mode enabled: false
2016-01-14 16:50:52,858 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:50:52,939 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:50:52,941 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0010
2016-01-14 16:50:52,941 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:50:52,950 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/D216295C9D63443EADADCFA91D6923AF/D2A4ABD6A59C4AD9AA5EA7396BC083E2/.tez/application_1452790096014_0010 doesn't exist and is created
2016-01-14 16:50:53,008 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0010, dagName=[D216295C9D63443EADADCFA91D6923AF/D2A4ABD6A59C4AD9AA5EA7396BC083E2] left+right/(1/1) ...platform/testSplit/split2
2016-01-14 16:50:53,012 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0010/
2016-01-14 16:50:53,106 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted tez dag to app master: application_1452790096014_0010, with dag id: dag_1452790096014_0010_1
2016-01-14 16:50:53,278 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0009_01_000002
2016-01-14 16:50:57,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0009_01_000004 is : 143
2016-01-14 16:50:57,573 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0009_01_000003 is : 143
2016-01-14 16:51:06,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:13.536, using cpu time: 00:03.020
2016-01-14 16:51:06,433 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplit/split2
2016-01-14 16:51:06,439 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplit/split1
2016-01-14 16:51:06,469 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:51:06,469 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:06,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 16:51:06,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 16:51:06,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:51:06,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:51:06,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:51:06,627 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: C9EDE053EB1240D2B4F27AFCAA78FEED,FAAFFF2B45FF48B9B23A0B1D6BE187A0 and A03B9E7E2B744CEFB5D10C9293B93C8E
2016-01-14 16:51:06,628 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/8CA7639ECA394A19903CB3958B0259B9/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:06,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 16:51:06,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:51:06,650 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2016-01-14 16:51:06,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2016-01-14 16:51:06,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2016-01-14 16:51:06,651 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2016-01-14 16:51:06,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2016-01-14 16:51:06,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tez session mode enabled: false
2016-01-14 16:51:06,668 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:51:06,761 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:51:06,762 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0011
2016-01-14 16:51:06,762 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:51:06,770 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/8CA7639ECA394A19903CB3958B0259B9/F2DD972E24234102A0C232DB64EA85E5/.tez/application_1452790096014_0011 doesn't exist and is created
2016-01-14 16:51:06,828 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0011, dagName=[8CA7639ECA394A19903CB3958B0259B9/F2DD972E24234102A0C232DB64EA85E5] merged/(1/1) ...eMerged/splitsourcemerged
2016-01-14 16:51:06,832 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0011/
2016-01-14 16:51:06,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted tez dag to app master: application_1452790096014_0011, with dag id: dag_1452790096014_0011_1
2016-01-14 16:51:11,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0010_01_000002 is : 143
2016-01-14 16:51:22,447 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:15.796, using cpu time: 00:07.610
2016-01-14 16:51:22,485 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2016-01-14 16:51:22,518 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:51:22,518 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:22,552 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-01-14 16:51:22,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 16:51:22,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:51:22,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:51:22,561 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:51:22,586 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/E18D6C8541A14101BF3131E4EA180945/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:22,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:51:22,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:51:22,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testCopy/copy"]
2016-01-14 16:51:22,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:51:22,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:51:22,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:51:22,610 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2016-01-14 16:51:22,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:51:22,630 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:51:22,726 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:51:22,727 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0012
2016-01-14 16:51:22,727 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:51:22,736 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/E18D6C8541A14101BF3131E4EA180945/A506566D14CA46699DACAFD8C2A3D9C8/.tez/application_1452790096014_0012 doesn't exist and is created
2016-01-14 16:51:22,791 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0012, dagName=[E18D6C8541A14101BF3131E4EA180945/A506566D14CA46699DACAFD8C2A3D9C8] test/(1/1) ...pesplatform/testCopy/copy
2016-01-14 16:51:22,795 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0012/
2016-01-14 16:51:22,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0012, with dag id: dag_1452790096014_0012_1
2016-01-14 16:51:24,397 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0011_01_000004
2016-01-14 16:51:27,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0011_01_000003 is : 143
2016-01-14 16:51:27,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0011_01_000002 is : 143
2016-01-14 16:51:34,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:12.333, using cpu time: 00:02.500
2016-01-14 16:51:34,971 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testCopy/copy
2016-01-14 16:51:35,002 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:51:35,002 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:35,047 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-14 16:51:35,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-14 16:51:35,063 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:51:35,063 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:51:35,063 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:51:35,146 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/F4EEFF3C757E46219CD02A5BBB3F1392/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:35,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:51:35,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:51:35,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testNone/none"]
2016-01-14 16:51:35,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:51:35,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:51:35,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:51:35,172 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2016-01-14 16:51:35,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:51:35,188 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:51:35,280 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:51:35,281 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0013
2016-01-14 16:51:35,281 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:51:35,290 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/F4EEFF3C757E46219CD02A5BBB3F1392/D6A3FC3BCC2544448C2BDC3362906109/.tez/application_1452790096014_0013 doesn't exist and is created
2016-01-14 16:51:35,349 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0013, dagName=[F4EEFF3C757E46219CD02A5BBB3F1392/D6A3FC3BCC2544448C2BDC3362906109] test/(1/1) ...pesplatform/testNone/none
2016-01-14 16:51:35,352 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0013/
2016-01-14 16:51:35,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0013, with dag id: dag_1452790096014_0013_1
2016-01-14 16:51:39,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0012_01_000002 is : 143
2016-01-14 16:51:49,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:14.692, using cpu time: 00:03.890
2016-01-14 16:51:49,895 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testNone/none
2016-01-14 16:51:49,939 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:51:49,940 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:49,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 16:51:50,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-14 16:51:50,013 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:51:50,013 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:51:50,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:51:50,086 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/F2E1F0CC44674500929BA4A39C16C83E/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:51:50,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:51:50,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:51:50,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSwap/swap"]
2016-01-14 16:51:50,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:51:50,109 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:51:50,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:51:50,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2016-01-14 16:51:50,124 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:51:50,126 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:51:50,209 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:51:50,210 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0014
2016-01-14 16:51:50,210 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:51:50,219 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/F2E1F0CC44674500929BA4A39C16C83E/C38375B535F94B858AC363A4438D3684/.tez/application_1452790096014_0014 doesn't exist and is created
2016-01-14 16:51:50,278 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0014, dagName=[F2E1F0CC44674500929BA4A39C16C83E/C38375B535F94B858AC363A4438D3684] test/(1/1) ...pesplatform/testSwap/swap
2016-01-14 16:51:50,281 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0014/
2016-01-14 16:51:50,371 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0014, with dag id: dag_1452790096014_0014_1
2016-01-14 16:51:51,476 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0013_01_000003
2016-01-14 16:51:51,571 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0013_01_000004
2016-01-14 16:51:54,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0013_01_000002 is : 143
2016-01-14 16:51:56,573 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0013
2016-01-14 16:52:05,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:15.250, using cpu time: 00:03.760
2016-01-14 16:52:05,392 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSwap/swap
2016-01-14 16:52:05,425 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:52:05,426 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:05,458 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 16:52:05,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-14 16:52:05,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:52:05,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:52:05,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:52:05,512 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/B5D386E1F59D4D838D9C6431DD611848/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:05,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:52:05,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:52:05,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testLogicFilter/logicfilter"]
2016-01-14 16:52:05,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:52:05,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:52:05,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:52:05,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2016-01-14 16:52:05,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:52:05,550 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:52:05,641 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:52:05,642 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0015
2016-01-14 16:52:05,642 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:52:05,653 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/B5D386E1F59D4D838D9C6431DD611848/BBB97D0319AC4040A7FFD4C68B5330A4/.tez/application_1452790096014_0015 doesn't exist and is created
2016-01-14 16:52:05,717 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0015, dagName=[B5D386E1F59D4D838D9C6431DD611848/BBB97D0319AC4040A7FFD4C68B5330A4] test/(1/1) ...stLogicFilter/logicfilter
2016-01-14 16:52:05,919 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0015/
2016-01-14 16:52:06,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0015, with dag id: dag_1452790096014_0015_1
2016-01-14 16:52:06,577 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0014_01_000003
2016-01-14 16:52:06,584 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0014_01_000004
2016-01-14 16:52:10,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0014_01_000002 is : 143
2016-01-14 16:52:11,371 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0014_01_000002
2016-01-14 16:52:11,586 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0014
2016-01-14 16:52:19,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:13.637, using cpu time: 00:02.690
2016-01-14 16:52:19,200 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testLogicFilter/logicfilter
2016-01-14 16:52:19,245 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:52:19,246 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:19,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 16:52:19,285 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 16:52:19,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:52:19,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:52:19,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:52:19,310 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/1F974F1BB07842E09D5220DDD16D6BCD/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:19,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:52:19,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 16:52:19,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testUnGroup/ungrouped"]
2016-01-14 16:52:19,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:52:19,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:52:19,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:52:19,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2016-01-14 16:52:19,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:52:19,364 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:52:19,448 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:52:19,450 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0016
2016-01-14 16:52:19,451 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:52:19,460 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/1F974F1BB07842E09D5220DDD16D6BCD/D82ED344DDB24373A680E54743F9E511/.tez/application_1452790096014_0016 doesn't exist and is created
2016-01-14 16:52:19,523 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0016, dagName=[1F974F1BB07842E09D5220DDD16D6BCD/D82ED344DDB24373A680E54743F9E511] test/(1/1) ...orm/testUnGroup/ungrouped
2016-01-14 16:52:19,526 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0016/
2016-01-14 16:52:19,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0016, with dag id: dag_1452790096014_0016_1
2016-01-14 16:52:24,202 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0015_01_000002 is : 143
2016-01-14 16:52:25,192 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0015_01_000002
2016-01-14 16:52:31,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:11.712, using cpu time: 00:02.570
2016-01-14 16:52:31,086 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testUnGroup/ungrouped
2016-01-14 16:52:31,126 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:52:31,127 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:31,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 16:52:31,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.044
2016-01-14 16:52:31,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:52:31,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:52:31,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:52:31,313 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/75F0095F4CC146F1A8B9993B8CF28BA0/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:31,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:52:31,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:52:31,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testFilterAll/filterall"]
2016-01-14 16:52:31,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:52:31,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:52:31,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:52:31,337 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...m/testFilterAll/filterall
2016-01-14 16:52:31,361 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:52:31,364 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:52:31,450 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:52:31,451 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0017
2016-01-14 16:52:31,452 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:52:31,460 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/75F0095F4CC146F1A8B9993B8CF28BA0/A5C166572A5E4DE2805510E8DAEDC7F9/.tez/application_1452790096014_0017 doesn't exist and is created
2016-01-14 16:52:31,518 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0017, dagName=[75F0095F4CC146F1A8B9993B8CF28BA0/A5C166572A5E4DE2805510E8DAEDC7F9] test/(1/1) ...m/testFilterAll/filterall
2016-01-14 16:52:31,521 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0017/
2016-01-14 16:52:31,622 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0017, with dag id: dag_1452790096014_0017_1
2016-01-14 16:52:36,084 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0016_01_000002 is : 143
2016-01-14 16:52:46,912 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0017_01_000005
2016-01-14 16:52:46,975 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0017_01_000006
2016-01-14 16:52:50,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:19.558, using cpu time: 00:09.150
2016-01-14 16:52:50,921 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testFilterAll/filterall
2016-01-14 16:52:50,948 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:52:50,948 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:50,996 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 16:52:51,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 16:52:51,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:52:51,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:52:51,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:52:51,098 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: F742D369708043D2A0FB5FB8475B34E0,E30DAFF28B14452BA018AEFD7D2C991E and E8D46CCC299F4E18A072D1C2674BF86E
2016-01-14 16:52:51,099 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/A87485E9A9884A5EB4DE976811100ACE/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:52:51,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2016-01-14 16:52:51,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:52:51,120 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2016-01-14 16:52:51,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2016-01-14 16:52:51,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2016-01-14 16:52:51,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2016-01-14 16:52:51,122 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2016-01-14 16:52:51,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tez session mode enabled: false
2016-01-14 16:52:51,139 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:52:51,228 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:52:51,230 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0018
2016-01-14 16:52:51,230 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:52:51,239 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/A87485E9A9884A5EB4DE976811100ACE/A17B19F9D7DF435F9C748FAA76E02488/.tez/application_1452790096014_0018 doesn't exist and is created
2016-01-14 16:52:51,301 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0018, dagName=[A87485E9A9884A5EB4DE976811100ACE/A17B19F9D7DF435F9C748FAA76E02488] merged/(1/1) ...splitsourcemergedsamename
2016-01-14 16:52:51,504 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0018/
2016-01-14 16:52:51,618 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted tez dag to app master: application_1452790096014_0018, with dag id: dag_1452790096014_0018_1
2016-01-14 16:52:53,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0017_01_000002 is : 143
2016-01-14 16:52:54,099 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0017_01_000002
2016-01-14 16:52:55,762 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0017_01_000003 is : 143
2016-01-14 16:52:55,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0017_01_000004 is : 143
2016-01-14 16:52:56,907 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0017_01_000004
2016-01-14 16:53:08,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:17.296, using cpu time: 00:08.150
2016-01-14 16:53:08,452 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2016-01-14 16:53:08,486 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:53:08,486 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:08,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 16:53:08,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.054
2016-01-14 16:53:08,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:53:08,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:53:08,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:53:08,724 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: E735B3AAB65243DC9454CD887D37EB8B,DB54AED68099433CA3E23C7E59F368EF and DB8ECDEEC26A420CB3837E9FE56AE638
2016-01-14 16:53:08,725 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/6CF9BDF3FA2142FFAE93C25B4D5E71A2/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:08,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting
2016-01-14 16:53:08,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/upper.txt"]
2016-01-14 16:53:08,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower.txt"]
2016-01-14 16:53:08,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2016-01-14 16:53:08,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  parallel execution of steps is enabled: true
2016-01-14 16:53:08,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  executing total steps: 1
2016-01-14 16:53:08,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  allocating management threads: 1
2016-01-14 16:53:08,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2016-01-14 16:53:08,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] tez session mode enabled: false
2016-01-14 16:53:08,765 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:53:08,848 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:53:08,850 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0019
2016-01-14 16:53:08,850 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:53:08,861 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/6CF9BDF3FA2142FFAE93C25B4D5E71A2/AF095F345DEA461D923F4869396BC019/.tez/application_1452790096014_0019 doesn't exist and is created
2016-01-14 16:53:08,917 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0019, dagName=[6CF9BDF3FA2142FFAE93C25B4D5E71A2/AF095F345DEA461D923F4869396BC019] groupby/(1/1) ...grouping-nondeterministic
2016-01-14 16:53:08,920 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0019/
2016-01-14 16:53:09,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] submitted tez dag to app master: application_1452790096014_0019, with dag id: dag_1452790096014_0019_1
2016-01-14 16:53:09,912 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0018_01_000004
2016-01-14 16:53:13,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0018_01_000002 is : 143
2016-01-14 16:53:13,483 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0018_01_000003 is : 143
2016-01-14 16:53:14,443 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0018_01_000002
2016-01-14 16:53:14,444 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0018_01_000003
2016-01-14 16:53:26,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  completed in: 00:18.212, using cpu time: 00:09.770
2016-01-14 16:53:26,991 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2016-01-14 16:53:27,022 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:53:27,022 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:27,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-01-14 16:53:27,064 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 16:53:27,064 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:53:27,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:53:27,065 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:53:27,087 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/CAED341CCBB447E4A551E0BD20715ADD/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:27,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:53:27,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower+upper.txt"]
2016-01-14 16:53:27,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2016-01-14 16:53:27,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:53:27,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:53:27,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:53:27,529 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2016-01-14 16:53:27,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:53:27,546 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:53:27,627 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:53:27,628 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0020
2016-01-14 16:53:27,629 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:53:27,637 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/CAED341CCBB447E4A551E0BD20715ADD/ED69B7BDC1F0418F8A53F4139971C17C/.tez/application_1452790096014_0020 doesn't exist and is created
2016-01-14 16:53:27,696 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0020, dagName=[CAED341CCBB447E4A551E0BD20715ADD/ED69B7BDC1F0418F8A53F4139971C17C] test/(1/1) ...UnGroupAnon/ungroupedanon
2016-01-14 16:53:27,702 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0020/
2016-01-14 16:53:27,764 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0019_01_000004
2016-01-14 16:53:27,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0020, with dag id: dag_1452790096014_0020_1
2016-01-14 16:53:31,989 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0019_01_000003 is : 143
2016-01-14 16:53:32,014 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0019_01_000002 is : 143
2016-01-14 16:53:41,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:13.528, using cpu time: 00:02.560
2016-01-14 16:53:41,088 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2016-01-14 16:53:41,114 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:53:41,114 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:41,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-14 16:53:41,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 16:53:41,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:53:41,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:53:41,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:53:41,289 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/55746C8A50934402B7FA11CE22F95937/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:53:41,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:53:41,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:53:41,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testGroupGroup/groupgroup"]
2016-01-14 16:53:41,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:53:41,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:53:41,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:53:41,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testGroupGroup/groupgroup
2016-01-14 16:53:41,327 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:53:41,330 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:53:41,414 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:53:41,415 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0021
2016-01-14 16:53:41,415 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:53:41,424 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/55746C8A50934402B7FA11CE22F95937/D66108A98D4A4E27A071F22223F9514A/.tez/application_1452790096014_0021 doesn't exist and is created
2016-01-14 16:53:41,479 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0021, dagName=[55746C8A50934402B7FA11CE22F95937/D66108A98D4A4E27A071F22223F9514A] test/(1/1) ...testGroupGroup/groupgroup
2016-01-14 16:53:41,481 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0021/
2016-01-14 16:53:41,564 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0021, with dag id: dag_1452790096014_0021_1
2016-01-14 16:53:46,082 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0020_01_000002 is : 143
2016-01-14 16:53:47,067 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0020_01_000002
2016-01-14 16:53:58,995 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0021_01_000004
2016-01-14 16:53:59,458 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0021_01_000005
2016-01-14 16:54:01,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:19.758, using cpu time: 00:07.100
2016-01-14 16:54:01,103 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testGroupGroup/groupgroup
2016-01-14 16:54:01,135 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:54:01,136 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:01,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.048
2016-01-14 16:54:01,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.053
2016-01-14 16:54:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:54:01,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 4
2016-01-14 16:54:01,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:54:01,317 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: D921A99393A942C8A0C1158B834A64B7,F3014F649A924CFAB13E7EC6F321CD87 and A2E7CFAE0994469AB1037434F89ED62A
2016-01-14 16:54:01,381 INFO  tez.Hadoop2TezFlowStep (Hadoop2TezFlowStep.java:createDAG(264)) - adding grouped edge between: BFB4BDFF608D42E2AA89FAEE8DAAD82B,D921A99393A942C8A0C1158B834A64B7 and F3014F649A924CFAB13E7EC6F321CD87
2016-01-14 16:54:01,383 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/513AE992099E49F3BEF057405AAD325F/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:01,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting
2016-01-14 16:54:01,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower.txt"]
2016-01-14 16:54:01,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2016-01-14 16:54:01,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  parallel execution of steps is enabled: true
2016-01-14 16:54:01,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  executing total steps: 1
2016-01-14 16:54:01,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  allocating management threads: 1
2016-01-14 16:54:01,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (1/1) .../samemergethreechaingroup
2016-01-14 16:54:01,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tez session mode enabled: false
2016-01-14 16:54:01,420 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:54:01,501 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:54:01,503 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0022
2016-01-14 16:54:01,503 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:54:01,511 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/513AE992099E49F3BEF057405AAD325F/CEFF86DCD7DE43289E9B97B9F235CC41/.tez/application_1452790096014_0022 doesn't exist and is created
2016-01-14 16:54:01,579 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0022, dagName=[513AE992099E49F3BEF057405AAD325F/CEFF86DCD7DE43289E9B97B9F235CC41] lower+upper+offset/(1/1) .../samemergethreechaingroup
2016-01-14 16:54:01,582 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0022/
2016-01-14 16:54:01,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted tez dag to app master: application_1452790096014_0022, with dag id: dag_1452790096014_0022_1
2016-01-14 16:54:04,896 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0021_01_000002 is : 143
2016-01-14 16:54:05,879 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0021_01_000002
2016-01-14 16:54:06,092 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0021_01_000003 is : 143
2016-01-14 16:54:07,078 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0021_01_000003
2016-01-14 16:54:16,789 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  completed in: 00:15.385, using cpu time: 00:08.940
2016-01-14 16:54:16,832 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2016-01-14 16:54:16,865 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:54:16,865 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:16,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 16:54:16,907 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 16:54:16,908 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:16,908 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:16,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:54:16,933 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/B05B0C06F13A48C2B7F9B740BF0948B8/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:16,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:54:16,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:54:16,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testReplace/replace"]
2016-01-14 16:54:16,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:54:16,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:54:16,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:54:16,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2016-01-14 16:54:16,974 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:54:16,978 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:54:17,073 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:54:17,074 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0023
2016-01-14 16:54:17,074 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:54:17,083 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/B05B0C06F13A48C2B7F9B740BF0948B8/CDF556F626F54AA8882F144EF30B45CB/.tez/application_1452790096014_0023 doesn't exist and is created
2016-01-14 16:54:17,143 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0023, dagName=[B05B0C06F13A48C2B7F9B740BF0948B8/CDF556F626F54AA8882F144EF30B45CB] test/(1/1) ...tform/testReplace/replace
2016-01-14 16:54:17,346 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0023/
2016-01-14 16:54:17,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0023, with dag id: dag_1452790096014_0023_1
2016-01-14 16:54:18,003 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0022_01_000004
2016-01-14 16:54:21,825 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0022_01_000003 is : 143
2016-01-14 16:54:21,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0022_01_000002 is : 143
2016-01-14 16:54:29,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:12.463, using cpu time: 00:02.460
2016-01-14 16:54:29,449 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testReplace/replace
2016-01-14 16:54:29,494 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:54:29,494 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:29,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.009
2016-01-14 16:54:29,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 16:54:29,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:29,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:29,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:54:29,573 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/2945BF508B95410B8B3531000F73C9B3/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:29,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:54:29,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/extra+lower+upper.txt"]
2016-01-14 16:54:29,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2016-01-14 16:54:29,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:54:29,595 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:54:29,596 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:54:29,597 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2016-01-14 16:54:29,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:54:29,615 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:54:29,700 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:54:29,701 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0024
2016-01-14 16:54:29,701 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:54:29,710 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/2945BF508B95410B8B3531000F73C9B3/A617068CA81A46BCAE8EEF820951473C/.tez/application_1452790096014_0024 doesn't exist and is created
2016-01-14 16:54:29,764 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0024, dagName=[2945BF508B95410B8B3531000F73C9B3/A617068CA81A46BCAE8EEF820951473C] test/(1/1) ...roupBySize/ungrouped_size
2016-01-14 16:54:29,766 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0024/
2016-01-14 16:54:29,858 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0024, with dag id: dag_1452790096014_0024_1
2016-01-14 16:54:34,438 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0023_01_000002 is : 143
2016-01-14 16:54:43,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:13.720, using cpu time: 00:02.620
2016-01-14 16:54:43,346 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2016-01-14 16:54:43,372 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:54:43,373 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:43,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.007
2016-01-14 16:54:43,415 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-14 16:54:43,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:43,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:54:43,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:54:43,441 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/FDBFBBE2C0174C1A98EC7F36EFF9F974/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:43,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:54:43,461 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:54:43,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testFilter/filter"]
2016-01-14 16:54:43,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:54:43,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:54:43,462 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:54:43,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2016-01-14 16:54:43,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:54:43,483 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:54:43,564 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:54:43,565 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0025
2016-01-14 16:54:43,565 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:54:43,573 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/FDBFBBE2C0174C1A98EC7F36EFF9F974/ACBE5ED6DF0B4D66AF234DD54D020387/.tez/application_1452790096014_0025 doesn't exist and is created
2016-01-14 16:54:43,641 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0025, dagName=[FDBFBBE2C0174C1A98EC7F36EFF9F974/ACBE5ED6DF0B4D66AF234DD54D020387] test/(1/1) ...latform/testFilter/filter
2016-01-14 16:54:43,644 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0025/
2016-01-14 16:54:43,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0025, with dag id: dag_1452790096014_0025_1
2016-01-14 16:54:48,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0024_01_000002 is : 143
2016-01-14 16:54:57,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:13.943, using cpu time: 00:02.500
2016-01-14 16:54:57,442 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testFilter/filter
2016-01-14 16:54:57,474 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:54:57,474 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:57,532 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 16:54:57,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.035
2016-01-14 16:54:57,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:54:57,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 3
2016-01-14 16:54:57,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:54:57,654 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/D9369B2C73AE4B0FA07B9D6E02906AFE/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:54:57,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting
2016-01-14 16:54:57,677 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:54:57,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitMultiple/left"]
2016-01-14 16:54:57,678 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitMultiple/rightright"]
2016-01-14 16:54:57,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitMultiple/rightleft"]
2016-01-14 16:54:57,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  parallel execution of steps is enabled: true
2016-01-14 16:54:57,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  executing total steps: 1
2016-01-14 16:54:57,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  allocating management threads: 1
2016-01-14 16:54:57,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (1/1) ...rm/testSplitMultiple/left
2016-01-14 16:54:57,705 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tez session mode enabled: false
2016-01-14 16:54:57,708 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:54:57,786 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:54:57,787 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0026
2016-01-14 16:54:57,787 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:54:57,796 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/D9369B2C73AE4B0FA07B9D6E02906AFE/FAAA9D9208B845C7BFDC324D2A7B099E/.tez/application_1452790096014_0026 doesn't exist and is created
2016-01-14 16:54:57,850 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0026, dagName=[D9369B2C73AE4B0FA07B9D6E02906AFE/FAAA9D9208B845C7BFDC324D2A7B099E] left+rightLeft+rightRight/(1/1) ...rm/testSplitMultiple/left
2016-01-14 16:54:57,853 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0026/
2016-01-14 16:54:57,931 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted tez dag to app master: application_1452790096014_0026, with dag id: dag_1452790096014_0026_1
2016-01-14 16:55:02,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0025_01_000002 is : 143
2016-01-14 16:55:13,427 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0026_01_000004
2016-01-14 16:55:13,481 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0026_01_000005
2016-01-14 16:55:14,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  completed in: 00:16.990, using cpu time: 00:07.470
2016-01-14 16:55:14,747 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitMultiple/rightright
2016-01-14 16:55:14,753 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitMultiple/left
2016-01-14 16:55:14,759 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitMultiple/rightleft
2016-01-14 16:55:14,788 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:55:14,788 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:14,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-14 16:55:14,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-14 16:55:14,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:55:14,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:55:14,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:55:14,919 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/2389372D21A847A39B91872FEA8F760D/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:14,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting
2016-01-14 16:55:14,939 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/upper.txt"]]]
2016-01-14 16:55:14,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testConcatenation/complexconcat"]
2016-01-14 16:55:14,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  parallel execution of steps is enabled: true
2016-01-14 16:55:14,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  executing total steps: 1
2016-01-14 16:55:14,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  allocating management threads: 1
2016-01-14 16:55:14,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2016-01-14 16:55:14,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] tez session mode enabled: false
2016-01-14 16:55:14,958 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:55:15,039 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:55:15,040 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0027
2016-01-14 16:55:15,040 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:55:15,049 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/2389372D21A847A39B91872FEA8F760D/E95C2310CF484866ACFDE938A9E391AE/.tez/application_1452790096014_0027 doesn't exist and is created
2016-01-14 16:55:15,102 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0027, dagName=[2389372D21A847A39B91872FEA8F760D/E95C2310CF484866ACFDE938A9E391AE] concat/(1/1) ...ncatenation/complexconcat
2016-01-14 16:55:15,105 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0027/
2016-01-14 16:55:15,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] submitted tez dag to app master: application_1452790096014_0027, with dag id: dag_1452790096014_0027_1
2016-01-14 16:55:18,504 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0026_01_000002 is : 143
2016-01-14 16:55:19,494 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0026_01_000002
2016-01-14 16:55:19,687 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0026_01_000003 is : 143
2016-01-14 16:55:21,484 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0026
2016-01-14 16:55:29,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  completed in: 00:14.593, using cpu time: 00:03.770
2016-01-14 16:55:29,566 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testConcatenation/complexconcat
2016-01-14 16:55:29,610 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:55:29,610 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:29,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-14 16:55:29,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 16:55:29,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:55:29,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 2
2016-01-14 16:55:29,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:55:29,739 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/8C6798AF66FC441DA2CA163DA79D4451/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:29,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 1
2016-01-14 16:55:29,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 1
2016-01-14 16:55:29,769 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/1) ...stSplitComplex/splitcomp2
2016-01-14 16:55:29,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tez session mode enabled: false
2016-01-14 16:55:29,785 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:55:29,872 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:55:29,873 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0028
2016-01-14 16:55:29,874 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:55:29,883 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/8C6798AF66FC441DA2CA163DA79D4451/F9B7EF98E634466AA3243B26D3C6BA88/.tez/application_1452790096014_0028 doesn't exist and is created
2016-01-14 16:55:29,937 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0028, dagName=[8C6798AF66FC441DA2CA163DA79D4451/F9B7EF98E634466AA3243B26D3C6BA88] left+right/(1/1) ...stSplitComplex/splitcomp2
2016-01-14 16:55:29,940 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0028/
2016-01-14 16:55:30,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted tez dag to app master: application_1452790096014_0028, with dag id: dag_1452790096014_0028_1
2016-01-14 16:55:31,487 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0027_01_000003
2016-01-14 16:55:34,567 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0027_01_000002 is : 143
2016-01-14 16:55:44,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:15.184, using cpu time: 00:03.860
2016-01-14 16:55:45,022 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitComplex/splitcomp2
2016-01-14 16:55:45,029 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testSplitComplex/splitcomp1
2016-01-14 16:55:45,060 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 16:55:45,061 INFO  planner.Hadoop2TezPlanner (Hadoop2TezPlanner.java:initialize(149)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:45,091 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: NoHashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.008
2016-01-14 16:55:45,098 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: HashJoinHadoop2TezRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-14 16:55:45,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:55:45,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: HashJoinHadoop2TezRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 16:55:45,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: NoHashJoinHadoop2TezRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 16:55:45,123 INFO  util.HadoopUtil (HadoopUtil.java:syncPaths(602)) - copying from: file:/opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-tez/3.0.4/561447ee876073bb61fddc52e2ad157f45c8edd/cascading-hadoop2-tez-3.0.4.jar, to: hdfs://localhost:39396/user/teamcity/.staging/022EFC5989DC4B32BF4AE37404DD18FB/cascading-hadoop2-tez-3.0.4.jar
2016-01-14 16:55:45,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2016-01-14 16:55:45,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/classes/test/data/apache.10.txt"]
2016-01-14 16:55:45,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output/hadoop2-tez/fieldedpipesplatform/testNoGroup/nogroup"]
2016-01-14 16:55:45,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2016-01-14 16:55:45,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2016-01-14 16:55:45,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2016-01-14 16:55:45,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2016-01-14 16:55:45,162 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tez session mode enabled: false
2016-01-14 16:55:45,165 INFO  client.TezClient (TezClient.java:<init>(153)) - Tez Client Version: [ component=tez-api, version=0.6.2, revision=c04283bf91fd96823eec37056d5c8b1a92728265, SCM-URL=scm:git:https://git-wip-us.apache.org/repos/asf/tez.git, buildTime=20150804-1436 ]
2016-01-14 16:55:45,246 INFO  client.TezClient (TezClient.java:start(315)) - Using org.apache.tez.dag.history.ats.acls.ATSHistoryACLPolicyManager to manage Timeline ACLs
2016-01-14 16:55:45,248 INFO  client.TezClient (TezClient.java:submitDAGApplication(738)) - Submitting DAG application with id: application_1452790096014_0029
2016-01-14 16:55:45,248 INFO  client.TezClientUtils (TezClientUtils.java:setupTezJarsLocalResources(171)) - Using tez.lib.uris value from configuration: hdfs://localhost:39396/user/teamcity/target/cascading.platform.tez.Hadoop2TezPlatform-tmpDir/TezAppJar.jar
2016-01-14 16:55:45,257 INFO  client.TezClient (TezCommonUtils.java:createTezSystemStagingPath(118)) - Tez system stage directory hdfs://localhost:39396/user/teamcity/.staging/022EFC5989DC4B32BF4AE37404DD18FB/D347CA945C9447388D7F3109B2D1E87F/.tez/application_1452790096014_0029 doesn't exist and is created
2016-01-14 16:55:45,324 INFO  client.TezClient (TezClient.java:submitDAGApplication(759)) - Submitting DAG to YARN, applicationId=application_1452790096014_0029, dagName=[022EFC5989DC4B32BF4AE37404DD18FB/D347CA945C9447388D7F3109B2D1E87F] test/(1/1) ...tform/testNoGroup/nogroup
2016-01-14 16:55:45,327 INFO  client.TezClient (TezClient.java:submitDAGApplication(765)) - The url to track the Tez AM: http://ip-10-187-41-40:33141/proxy/application_1452790096014_0029/
2016-01-14 16:55:45,405 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted tez dag to app master: application_1452790096014_0029, with dag id: dag_1452790096014_0029_1
2016-01-14 16:55:46,497 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0028_01_000004
2016-01-14 16:55:46,497 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0028_01_000003
2016-01-14 16:55:49,977 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1452790096014_0028_01_000002 is : 143
2016-01-14 16:55:50,966 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(842)) - Event EventType: KILL_CONTAINER sent to absent container container_1452790096014_0028_01_000002
2016-01-14 16:55:51,501 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(858)) - Event EventType: FINISH_APPLICATION sent to absent application application_1452790096014_0028
2016-01-14 16:55:58,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:13.397, using cpu time: 00:02.670
2016-01-14 16:55:58,599 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ca57560bc31094a7/apache-2.5.x-tez-0.6.x/build/test/output//hadoop2-tez/fieldedpipesplatform/testNoGroup/nogroup

Standard error

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