The testing code for Yarn is very fragile. Also, I'm puzzled why the code to test the VCores setting is in the TaskManagerFailure test. Running some more tests to fix the issue.
On Tue, Sep 6, 2016 at 7:28 AM, Vijay Srinivasaraghavan <vijikar...@yahoo.com.invalid> wrote: > Hi Max, > I have pulled and tested with the latest master, but I am still seeing some > issues. > -------------------------------------------------------------------------------Test > set: > org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase-------------------------------------------------------------------------------Tests > run: 7, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 96.989 sec <<< > FAILURE! - in > org.apache.flink.yarn.YARNSessionCapacitySchedulerITCasetestTaskManagerFailure(org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase) > Time elapsed: 14.128 sec <<< FAILURE!java.lang.AssertionError: null > at org.junit.Assert.fail(Assert.java:86) at > org.junit.Assert.assertTrue(Assert.java:41) at > org.junit.Assert.assertTrue(Assert.java:52) at > org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.testTaskManagerFailure(YARNSessionCapacitySchedulerITCase.java:262) > testNonexistingQueue(org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase) > Time elapsed: 0.569 sec <<< FAILURE!java.lang.AssertionError: There is at > least one application on the cluster is not finished.App > application_1473139321658_0006 is in state RUNNING at > org.junit.Assert.fail(Assert.java:88) at > org.apache.flink.yarn.YarnTestBase.checkClusterEmpty(YarnTestBase.java:171) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47) > at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44) > at > org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24) > at > org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) > at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55) at > org.junit.rules.RunRules.evaluate(RunRules.java:20) at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271) at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70) > at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50) > at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238) > at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63) at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236) at > org.junit.runners.ParentRunner.access$000(ParentRunner.java:53) at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229) at > org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) > at > org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) > at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) at > org.junit.runners.ParentRunner.run(ParentRunner.java:309) at > org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:283) > at > org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:173) > at > org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153) > at > org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:128) > at > org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203) > at > org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155) > RegardsVijay > > On Monday, September 5, 2016 7:28 AM, Maximilian Michels > <m...@apache.org> wrote: > > > Hi Vijay, > > The test fails when a NodeReport with used resources set to null is > retrieved. The test assumes that a TaskManager is always exclusively > running in one Yarn NodeManager which doesn't have to be true as one > NodeManager can host multiple containers. The test only seems to > reliably fail when the it's executed exclusively where a dedicated > Yarn mini cluster is started only for the test. > > The problem is fixed on the latest master. > > Thanks, > Max > > On Sun, Sep 4, 2016 at 11:21 PM, Vijay Srinivasaraghavan > <vijikar...@yahoo.com.invalid> wrote: >> Hi Robert, >> Yes, I am consistently seeing the issue. Here is the stack track for the run. >>> mvn test integration-test >>> -Dtest="YARNSessionCapacitySchedulerITCase#testTaskManagerFailure" >>> -Pinclude-yarn-tests -pl flink-yarn-tests -DfailIfNoTests=false >> >> [INFO] Scanning for projects...[INFO] >> [INFO] >> ------------------------------------------------------------------------[INFO] >> Building flink-yarn-tests 1.2-SNAPSHOT[INFO] >> ------------------------------------------------------------------------[INFO] >> [INFO] --- maven-checkstyle-plugin:2.17:check (validate) @ >> flink-yarn-tests_2.10 ---[INFO] [INFO] --- >> maven-enforcer-plugin:1.3.1:enforce (enforce-maven) @ flink-yarn-tests_2.10 >> ---[INFO] [INFO] --- build-helper-maven-plugin:1.7:add-source (add-source) @ >> flink-yarn-tests_2.10 ---[INFO] Source directory: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/main/scala >> added.[INFO] [INFO] --- maven-remote-resources-plugin:1.5:process (default) >> @ flink-yarn-tests_2.10 ---[INFO] [INFO] --- >> maven-resources-plugin:2.6:resources (default-resources) @ >> flink-yarn-tests_2.10 ---[INFO] Using 'UTF-8' encoding to copy filtered >> resources.[INFO] skip non existing resourceDirectory >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/main/resources[INFO] >> Copying 3 resources[INFO] [INFO] --- scala-maven-plugin:3.1.4:compile >> (scala-compile-first) @ flink-yarn-tests_2.10 ---[INFO] No sources to >> compile[INFO] [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) >> @ flink-yarn-tests_2.10 ---[INFO] No sources to compile[INFO] [INFO] --- >> build-helper-maven-plugin:1.7:add-test-source (add-test-source) @ >> flink-yarn-tests_2.10 ---[INFO] Test Source directory: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/test/scala >> added.[INFO] [INFO] --- maven-resources-plugin:2.6:testResources >> (default-testResources) @ flink-yarn-tests_2.10 ---[INFO] Using 'UTF-8' >> encoding to copy filtered resources.[INFO] Copying 1 resource[INFO] Copying >> 3 resources[INFO] [INFO] --- scala-maven-plugin:3.1.4:testCompile >> (scala-test-compile) @ flink-yarn-tests_2.10 ---[INFO] Nothing to compile - >> all classes are up to date[INFO] [INFO] --- >> maven-compiler-plugin:3.1:testCompile (default-testCompile) @ >> flink-yarn-tests_2.10 ---[INFO] Nothing to compile - all classes are up to >> date[INFO] [INFO] --- maven-surefire-plugin:2.18.1:test (default-test) @ >> flink-yarn-tests_2.10 ---[INFO] [INFO] --- >> maven-checkstyle-plugin:2.17:check (validate) @ flink-yarn-tests_2.10 >> ---[INFO] [INFO] --- maven-enforcer-plugin:1.3.1:enforce (enforce-maven) @ >> flink-yarn-tests_2.10 ---[INFO] [INFO] --- >> build-helper-maven-plugin:1.7:add-source (add-source) @ >> flink-yarn-tests_2.10 ---[INFO] Source directory: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/main/scala >> added.[INFO] [INFO] --- maven-remote-resources-plugin:1.5:process (default) >> @ flink-yarn-tests_2.10 ---[INFO] [INFO] --- >> maven-resources-plugin:2.6:resources (default-resources) @ >> flink-yarn-tests_2.10 ---[INFO] Using 'UTF-8' encoding to copy filtered >> resources.[INFO] skip non existing resourceDirectory >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/main/resources[INFO] >> Copying 3 resources[INFO] Copying 3 resources[INFO] [INFO] --- >> scala-maven-plugin:3.1.4:compile (scala-compile-first) @ >> flink-yarn-tests_2.10 ---[INFO] No sources to compile[INFO] [INFO] --- >> maven-compiler-plugin:3.1:compile (default-compile) @ flink-yarn-tests_2.10 >> ---[INFO] No sources to compile[INFO] [INFO] --- >> build-helper-maven-plugin:1.7:add-test-source (add-test-source) @ >> flink-yarn-tests_2.10 ---[INFO] Test Source directory: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/src/test/scala >> added.[INFO] [INFO] --- maven-resources-plugin:2.6:testResources >> (default-testResources) @ flink-yarn-tests_2.10 ---[INFO] Using 'UTF-8' >> encoding to copy filtered resources.[INFO] Copying 1 resource[INFO] Copying >> 3 resources[INFO] Copying 3 resources[INFO] [INFO] --- >> scala-maven-plugin:3.1.4:testCompile (scala-test-compile) @ >> flink-yarn-tests_2.10 ---[INFO] Nothing to compile - all classes are up to >> date[INFO] [INFO] --- maven-compiler-plugin:3.1:testCompile >> (default-testCompile) @ flink-yarn-tests_2.10 ---[INFO] Nothing to compile - >> all classes are up to date[INFO] [INFO] --- >> maven-surefire-plugin:2.18.1:test (default-test) @ flink-yarn-tests_2.10 >> ---[INFO] Skipping execution of surefire because it has already been run for >> this configuration[INFO] [INFO] --- maven-jar-plugin:2.4:jar (default-jar) @ >> flink-yarn-tests_2.10 ---[INFO] Building jar: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT.jar[INFO] >> [INFO] --- maven-site-plugin:3.3:attach-descriptor (attach-descriptor) @ >> flink-yarn-tests_2.10 ---[INFO] [INFO] --- maven-jar-plugin:2.4:test-jar >> (default) @ flink-yarn-tests_2.10 ---[INFO] Building jar: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT-tests.jar[INFO] >> [INFO] --- maven-shade-plugin:2.4.1:shade (shade-flink) @ >> flink-yarn-tests_2.10 ---[INFO] Excluding >> org.apache.commons:commons-math3:jar:3.5 from the shaded jar.[INFO] >> Excluding io.netty:netty:jar:3.8.0.Final from the shaded jar.[INFO] >> Excluding commons-cli:commons-cli:jar:1.3.1 from the shaded jar.[INFO] >> Excluding xmlenc:xmlenc:jar:0.52 from the shaded jar.[INFO] Excluding >> commons-codec:commons-codec:jar:1.4 from the shaded jar.[INFO] Excluding >> commons-io:commons-io:jar:2.4 from the shaded jar.[INFO] Excluding >> commons-net:commons-net:jar:3.1 from the shaded jar.[INFO] Excluding >> commons-collections:commons-collections:jar:3.2.2 from the shaded jar.[INFO] >> Excluding javax.servlet:servlet-api:jar:2.5 from the shaded jar.[INFO] >> Excluding org.mortbay.jetty:jetty-util:jar:6.1.26 from the shaded jar.[INFO] >> Excluding com.sun.jersey:jersey-core:jar:1.9 from the shaded jar.[INFO] >> Excluding commons-el:commons-el:jar:1.0 from the shaded jar.[INFO] Excluding >> commons-logging:commons-logging:jar:1.1.3 from the shaded jar.[INFO] >> Excluding com.jamesmurty.utils:java-xmlbuilder:jar:0.4 from the shaded >> jar.[INFO] Excluding commons-lang:commons-lang:jar:2.6 from the shaded >> jar.[INFO] Excluding commons-configuration:commons-configuration:jar:1.7 >> from the shaded jar.[INFO] Excluding >> commons-digester:commons-digester:jar:1.8.1 from the shaded jar.[INFO] >> Excluding org.codehaus.jackson:jackson-core-asl:jar:1.8.8 from the shaded >> jar.[INFO] Excluding org.codehaus.jackson:jackson-mapper-asl:jar:1.8.8 from >> the shaded jar.[INFO] Excluding org.apache.avro:avro:jar:1.7.6 from the >> shaded jar.[INFO] Excluding com.thoughtworks.paranamer:paranamer:jar:2.3 >> from the shaded jar.[INFO] Excluding org.xerial.snappy:snappy-java:jar:1.0.5 >> from the shaded jar.[INFO] Excluding com.jcraft:jsch:jar:0.1.42 from the >> shaded jar.[INFO] Excluding org.apache.zookeeper:zookeeper:jar:3.4.6 from >> the shaded jar.[INFO] Excluding >> org.apache.commons:commons-compress:jar:1.4.1 from the shaded jar.[INFO] >> Excluding org.tukaani:xz:jar:1.0 from the shaded jar.[INFO] Excluding >> commons-daemon:commons-daemon:jar:1.0.13 from the shaded jar.[INFO] >> Excluding javax.xml.bind:jaxb-api:jar:2.2.2 from the shaded jar.[INFO] >> Excluding javax.xml.stream:stax-api:jar:1.0-2 from the shaded jar.[INFO] >> Excluding javax.activation:activation:jar:1.1 from the shaded jar.[INFO] >> Excluding com.google.inject:guice:jar:3.0 from the shaded jar.[INFO] >> Excluding javax.inject:javax.inject:jar:1 from the shaded jar.[INFO] >> Excluding aopalliance:aopalliance:jar:1.0 from the shaded jar.[INFO] >> Excluding org.apache.flink:flink-shaded-include-yarn-tests:jar:1.2-SNAPSHOT >> from the shaded jar.[INFO] Excluding org.mortbay.jetty:jetty:jar:6.1.26 from >> the shaded jar.[INFO] Excluding com.sun.jersey:jersey-json:jar:1.9 from the >> shaded jar.[INFO] Excluding com.sun.xml.bind:jaxb-impl:jar:2.2.3-1 from the >> shaded jar.[INFO] Excluding org.codehaus.jackson:jackson-jaxrs:jar:1.8.3 >> from the shaded jar.[INFO] Excluding >> org.codehaus.jackson:jackson-xc:jar:1.8.3 from the shaded jar.[INFO] >> Excluding com.sun.jersey:jersey-server:jar:1.9 from the shaded jar.[INFO] >> Excluding tomcat:jasper-compiler:jar:5.5.23 from the shaded jar.[INFO] >> Excluding tomcat:jasper-runtime:jar:5.5.23 from the shaded jar.[INFO] >> Excluding javax.servlet.jsp:jsp-api:jar:2.1 from the shaded jar.[INFO] >> Excluding commons-beanutils:commons-beanutils:jar:1.8.3 from the shaded >> jar.[INFO] Excluding com.google.inject.extensions:guice-servlet:jar:3.0 from >> the shaded jar.[INFO] Excluding com.sun.jersey.contribs:jersey-guice:jar:1.9 >> from the shaded jar.[INFO] Excluding org.codehaus.jettison:jettison:jar:1.1 >> from the shaded jar.[INFO] Excluding com.sun.jersey:jersey-client:jar:1.9 >> from the shaded jar.[INFO] Excluding >> org.apache.hadoop:hadoop-minikdc:jar:2.7.2 from the shaded jar.[INFO] >> Excluding org.apache.directory.server:apacheds-core-api:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-core-constants:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-i18n:jar:2.0.0-M15 from the shaded >> jar.[INFO] Excluding org.apache.directory.api:api-i18n:jar:1.0.0-M20 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.api:api-asn1-api:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-client-api:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-codec-core:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-aci:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-util:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding org.apache.directory.api:api-ldap-model:jar:1.0.0-M20 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.api:api-util:jar:1.0.0-M20 from the shaded jar.[INFO] >> Excluding org.apache.mina:mina-core:jar:2.0.7 from the shaded jar.[INFO] >> Excluding net.sf.ehcache:ehcache-core:jar:2.4.4 from the shaded jar.[INFO] >> Excluding >> org.apache.directory.server:apacheds-interceptor-kerberos:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-core:jar:2.0.0-M15 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-admin:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-authn:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-authz:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-changelog:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-collective:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-event:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-exception:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-journal:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-normalization:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-operational:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-referral:jar:2.0.0-M15 >> from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-schema:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-subtree:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-interceptors-trigger:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-trigger:jar:1.0.0-M20 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-kerberos-codec:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-protocol-shared:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-protocol-kerberos:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-core-shared:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-ldif-partition:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-xdbm-partition:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-mavibot-partition:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.mavibot:mavibot:jar:1.0.0-M1 from the shaded jar.[INFO] >> Excluding org.apache.directory.server:apacheds-core-avl:jar:2.0.0-M15 from >> the shaded jar.[INFO] Excluding >> org.apache.directory.api:api-all:jar:1.0.0-M20 from the shaded jar.[INFO] >> Excluding commons-pool:commons-pool:jar:1.6 from the shaded jar.[INFO] >> Excluding antlr:antlr:jar:2.7.7 from the shaded jar.[INFO] Excluding >> org.apache.directory.server:apacheds-jdbm-partition:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.jdbm:apacheds-jdbm1:bundle:2.0.0-M2 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.server:apacheds-protocol-ldap:jar:2.0.0-M15 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.api:api-asn1-ber:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-codec-api:jar:1.0.0-M20 from the >> shaded jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-codec:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding >> org.apache.directory.api:api-ldap-extras-sp:jar:1.0.0-M20 from the shaded >> jar.[INFO] Excluding bouncycastle:bcprov-jdk15:jar:140 from the shaded >> jar.[INFO] Including org.apache.flink:force-shading:jar:1.2-SNAPSHOT in the >> shaded jar.[INFO] Excluding com.google.code.findbugs:jsr305:jar:1.3.9 from >> the shaded jar.[INFO] Excluding org.apache.commons:commons-lang3:jar:3.3.2 >> from the shaded jar.[INFO] Excluding org.slf4j:slf4j-api:jar:1.7.7 from the >> shaded jar.[INFO] Excluding org.slf4j:slf4j-log4j12:jar:1.7.7 from the >> shaded jar.[INFO] Excluding log4j:log4j:jar:1.2.17 from the shaded >> jar.[INFO] Replacing original artifact with shaded artifact.[INFO] Replacing >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT.jar >> with >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT-shaded.jar[INFO] >> Replacing original test artifact with shaded test artifact.[INFO] Replacing >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT-tests.jar >> with >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT-shaded-tests.jar[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> [INFO] --- maven-shade-plugin:2.4.1:shade (shade-hadoop) @ >> flink-yarn-tests_2.10 ---[INFO] Including >> org.apache.commons:commons-math3:jar:3.5 in the shaded jar.[INFO] Including >> io.netty:netty:jar:3.8.0.Final in the shaded jar.[INFO] Including >> commons-cli:commons-cli:jar:1.3.1 in the shaded jar.[INFO] Including >> xmlenc:xmlenc:jar:0.52 in the shaded jar.[INFO] Including >> commons-codec:commons-codec:jar:1.4 in the shaded jar.[INFO] Including >> commons-io:commons-io:jar:2.4 in the shaded jar.[INFO] Including >> commons-net:commons-net:jar:3.1 in the shaded jar.[INFO] Including >> commons-collections:commons-collections:jar:3.2.2 in the shaded jar.[INFO] >> Including javax.servlet:servlet-api:jar:2.5 in the shaded jar.[INFO] >> Including org.mortbay.jetty:jetty-util:jar:6.1.26 in the shaded jar.[INFO] >> Including com.sun.jersey:jersey-core:jar:1.9 in the shaded jar.[INFO] >> Including commons-el:commons-el:jar:1.0 in the shaded jar.[INFO] Including >> commons-logging:commons-logging:jar:1.1.3 in the shaded jar.[INFO] Including >> com.jamesmurty.utils:java-xmlbuilder:jar:0.4 in the shaded jar.[INFO] >> Including commons-lang:commons-lang:jar:2.6 in the shaded jar.[INFO] >> Including commons-configuration:commons-configuration:jar:1.7 in the shaded >> jar.[INFO] Including commons-digester:commons-digester:jar:1.8.1 in the >> shaded jar.[INFO] Including org.codehaus.jackson:jackson-core-asl:jar:1.8.8 >> in the shaded jar.[INFO] Including >> org.codehaus.jackson:jackson-mapper-asl:jar:1.8.8 in the shaded jar.[INFO] >> Including org.apache.avro:avro:jar:1.7.6 in the shaded jar.[INFO] Including >> com.thoughtworks.paranamer:paranamer:jar:2.3 in the shaded jar.[INFO] >> Including org.xerial.snappy:snappy-java:jar:1.0.5 in the shaded jar.[INFO] >> Including com.jcraft:jsch:jar:0.1.42 in the shaded jar.[INFO] Including >> org.apache.zookeeper:zookeeper:jar:3.4.6 in the shaded jar.[INFO] Including >> org.apache.commons:commons-compress:jar:1.4.1 in the shaded jar.[INFO] >> Including org.tukaani:xz:jar:1.0 in the shaded jar.[INFO] Including >> commons-daemon:commons-daemon:jar:1.0.13 in the shaded jar.[INFO] Including >> javax.xml.bind:jaxb-api:jar:2.2.2 in the shaded jar.[INFO] Including >> javax.xml.stream:stax-api:jar:1.0-2 in the shaded jar.[INFO] Including >> javax.activation:activation:jar:1.1 in the shaded jar.[INFO] Including >> com.google.inject:guice:jar:3.0 in the shaded jar.[INFO] Including >> javax.inject:javax.inject:jar:1 in the shaded jar.[INFO] Including >> aopalliance:aopalliance:jar:1.0 in the shaded jar.[INFO] Including >> org.apache.flink:flink-shaded-include-yarn-tests:jar:1.2-SNAPSHOT in the >> shaded jar.[INFO] Including org.mortbay.jetty:jetty:jar:6.1.26 in the shaded >> jar.[INFO] Including com.sun.jersey:jersey-json:jar:1.9 in the shaded >> jar.[INFO] Including com.sun.xml.bind:jaxb-impl:jar:2.2.3-1 in the shaded >> jar.[INFO] Including org.codehaus.jackson:jackson-jaxrs:jar:1.8.3 in the >> shaded jar.[INFO] Including org.codehaus.jackson:jackson-xc:jar:1.8.3 in the >> shaded jar.[INFO] Including com.sun.jersey:jersey-server:jar:1.9 in the >> shaded jar.[INFO] Including tomcat:jasper-compiler:jar:5.5.23 in the shaded >> jar.[INFO] Including tomcat:jasper-runtime:jar:5.5.23 in the shaded >> jar.[INFO] Including javax.servlet.jsp:jsp-api:jar:2.1 in the shaded >> jar.[INFO] Including commons-beanutils:commons-beanutils:jar:1.8.3 in the >> shaded jar.[INFO] Including >> com.google.inject.extensions:guice-servlet:jar:3.0 in the shaded jar.[INFO] >> Including com.sun.jersey.contribs:jersey-guice:jar:1.9 in the shaded >> jar.[INFO] Including org.codehaus.jettison:jettison:jar:1.1 in the shaded >> jar.[INFO] Including com.sun.jersey:jersey-client:jar:1.9 in the shaded >> jar.[INFO] Including org.apache.hadoop:hadoop-minikdc:jar:2.7.2 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-core-api:jar:2.0.0-M15 in the shaded >> jar.[INFO] Including >> org.apache.directory.server:apacheds-core-constants:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-i18n:jar:2.0.0-M15 in the shaded >> jar.[INFO] Including org.apache.directory.api:api-i18n:jar:1.0.0-M20 in the >> shaded jar.[INFO] Including >> org.apache.directory.api:api-asn1-api:jar:1.0.0-M20 in the shaded jar.[INFO] >> Including org.apache.directory.api:api-ldap-client-api:jar:1.0.0-M20 in the >> shaded jar.[INFO] Including >> org.apache.directory.api:api-ldap-codec-core:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including >> org.apache.directory.api:api-ldap-extras-aci:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including >> org.apache.directory.api:api-ldap-extras-util:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including org.apache.directory.api:api-ldap-model:jar:1.0.0-M20 >> in the shaded jar.[INFO] Including >> org.apache.directory.api:api-util:jar:1.0.0-M20 in the shaded jar.[INFO] >> Including org.apache.mina:mina-core:jar:2.0.7 in the shaded jar.[INFO] >> Including net.sf.ehcache:ehcache-core:jar:2.4.4 in the shaded jar.[INFO] >> Including >> org.apache.directory.server:apacheds-interceptor-kerberos:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-core:jar:2.0.0-M15 in the shaded >> jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-admin:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-authn:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-authz:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-changelog:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-collective:jar:2.0.0-M15 >> in the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-event:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-exception:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-journal:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-normalization:jar:2.0.0-M15 >> in the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-operational:jar:2.0.0-M15 >> in the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-referral:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-schema:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-subtree:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-interceptors-trigger:jar:2.0.0-M15 in >> the shaded jar.[INFO] Including >> org.apache.directory.api:api-ldap-extras-trigger:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including >> org.apache.directory.server:apacheds-kerberos-codec:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-protocol-shared:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-protocol-kerberos:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-core-shared:jar:2.0.0-M15 in the shaded >> jar.[INFO] Including >> org.apache.directory.server:apacheds-ldif-partition:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-xdbm-partition:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.server:apacheds-mavibot-partition:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.mavibot:mavibot:jar:1.0.0-M1 in the shaded jar.[INFO] >> Including org.apache.directory.server:apacheds-core-avl:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including org.apache.directory.api:api-all:jar:1.0.0-M20 >> in the shaded jar.[INFO] Including commons-pool:commons-pool:jar:1.6 in the >> shaded jar.[INFO] Including antlr:antlr:jar:2.7.7 in the shaded jar.[INFO] >> Including org.apache.directory.server:apacheds-jdbm-partition:jar:2.0.0-M15 >> in the shaded jar.[INFO] Including >> org.apache.directory.jdbm:apacheds-jdbm1:bundle:2.0.0-M2 in the shaded >> jar.[INFO] Including >> org.apache.directory.server:apacheds-protocol-ldap:jar:2.0.0-M15 in the >> shaded jar.[INFO] Including >> org.apache.directory.api:api-asn1-ber:jar:1.0.0-M20 in the shaded jar.[INFO] >> Including org.apache.directory.api:api-ldap-extras-codec-api:jar:1.0.0-M20 >> in the shaded jar.[INFO] Including >> org.apache.directory.api:api-ldap-extras-codec:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including >> org.apache.directory.api:api-ldap-extras-sp:jar:1.0.0-M20 in the shaded >> jar.[INFO] Including bouncycastle:bcprov-jdk15:jar:140 in the shaded >> jar.[INFO] Including org.apache.flink:force-shading:jar:1.2-SNAPSHOT in the >> shaded jar.[INFO] Including com.google.code.findbugs:jsr305:jar:1.3.9 in the >> shaded jar.[INFO] Including org.apache.commons:commons-lang3:jar:3.3.2 in >> the shaded jar.[INFO] Including org.slf4j:slf4j-api:jar:1.7.7 in the shaded >> jar.[INFO] Including org.slf4j:slf4j-log4j12:jar:1.7.7 in the shaded >> jar.[INFO] Including log4j:log4j:jar:1.2.17 in the shaded jar.[WARNING] >> api-i18n-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 1 overlapping classes: >> [WARNING] - org.apache.directory.api.i18n.I18n[WARNING] >> jasper-runtime-5.5.23.jar, jasper-compiler-5.5.23.jar define 1 overlapping >> classes: [WARNING] - org.apache.jasper.compiler.Localizer[WARNING] >> api-ldap-extras-codec-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 145 >> overlapping classes: [WARNING] - >> org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncRequestValueGrammar$4[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncInfoValueStatesEnum[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.ads_impl.storedProcedure.StoredProcedureContainer[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.ads_impl.pwdModify.PasswordModifyResponseDecoder[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncInfoValueGrammar$14[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.ads_impl.pwdModify.PasswordModifyRequestGrammar$1[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.ppolicy_impl.StoreGraceAuthNRemaining[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.ads_impl.certGeneration.CertGenerationGrammar$1[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.ppolicy_impl.PasswordPolicyFactory[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.ppolicy_impl.PasswordPolicyContainer[WARNING] >> - 135 more...[WARNING] api-all-1.0.0-M20.jar, >> api-ldap-extras-aci-1.0.0-M20.jar define 47 overlapping classes: [WARNING] >> - org.apache.directory.api.ldap.aci.UserClass$ThisEntry[WARNING] - >> org.apache.directory.api.ldap.aci.protectedItem.MaxImmSubItem[WARNING] - >> org.apache.directory.api.ldap.aci.ReusableAntlrACIItemParser[WARNING] - >> org.apache.directory.api.ldap.aci.ACIItemChecker[WARNING] - >> org.apache.directory.api.ldap.aci.ACIItemParser[WARNING] - >> org.apache.directory.api.ldap.aci.protectedItem.EntryItem[WARNING] - >> org.apache.directory.api.ldap.aci.Permission[WARNING] - >> org.apache.directory.api.ldap.aci.protectedItem.RestrictedByElem[WARNING] - >> org.apache.directory.api.ldap.aci.UserClass$UserGroup[WARNING] - >> org.apache.directory.api.ldap.aci.AntlrACIItemLexer[WARNING] - 37 >> more...[WARNING] api-asn1-api-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 9 >> overlapping classes: [WARNING] - >> org.apache.directory.api.asn1.EncoderException[WARNING] - >> org.apache.directory.api.asn1.Decoder[WARNING] - >> org.apache.directory.api.asn1.DecoderException[WARNING] - >> org.apache.directory.api.asn1.util.BitString[WARNING] - >> org.apache.directory.api.asn1.Encoder[WARNING] - >> org.apache.directory.api.asn1.Asn1Object[WARNING] - >> org.apache.directory.api.asn1.util.Asn1StringUtils[WARNING] - >> org.apache.directory.api.asn1.AbstractAsn1Object[WARNING] - >> org.apache.directory.api.asn1.util.Oid[WARNING] >> api-ldap-model-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 530 overlapping >> classes: [WARNING] - >> org.apache.directory.api.ldap.model.ldif.LdifControl[WARNING] - >> org.apache.directory.api.ldap.model.constants.SupportedSaslMechanisms[WARNING] >> - >> org.apache.directory.api.ldap.model.schema.syntaxes.AntlrSchemaParser$NoidLen[WARNING] >> - >> org.apache.directory.api.ldap.model.schema.comparators.NumericStringComparator[WARNING] >> - >> org.apache.directory.api.ldap.model.schema.syntaxes.AntlrSchemaExtensionParser[WARNING] >> - org.apache.directory.api.ldap.model.filter.NotNode[WARNING] - >> org.apache.directory.api.ldap.model.schema.syntaxes.AntlrSchemaParser[WARNING] >> - >> org.apache.directory.api.ldap.model.exception.LdapNoSuchAttributeException[WARNING] >> - org.apache.directory.api.ldap.model.cursor.CursorStateEnum[WARNING] - >> org.apache.directory.api.ldap.model.message.AliasDerefMode$1[WARNING] - 520 >> more...[WARNING] api-util-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 42 >> overlapping classes: [WARNING] - >> org.apache.directory.api.util.SequencedHashMap$2[WARNING] - >> org.apache.directory.api.util.DummySSLSocketFactory$1[WARNING] - >> org.apache.directory.api.util.AbstractSimpleComponentsMonitor[WARNING] - >> org.apache.directory.api.util.Strings[WARNING] - >> org.apache.directory.api.util.SequencedHashMap$OrderedIterator[WARNING] - >> org.apache.directory.api.util.Unicode[WARNING] - >> org.apache.directory.api.util.exception.NotImplementedException[WARNING] - >> org.apache.directory.api.util.OsgiUtils[WARNING] - >> org.apache.directory.api.util.MandatoryComponentsMonitor[WARNING] - >> org.apache.directory.api.util.exception.RuntimeMultiException[WARNING] - 32 >> more...[WARNING] api-all-1.0.0-M20.jar, api-ldap-codec-core-1.0.0-M20.jar >> define 195 overlapping classes: [WARNING] - >> org.apache.directory.api.ldap.codec.osgi.DefaultLdapCodecService$1[WARNING] >> - >> org.apache.directory.api.ldap.codec.actions.modifyDnResponse.InitModifyDnResponse[WARNING] >> - >> org.apache.directory.api.ldap.codec.actions.unbindRequest.InitUnbindRequest[WARNING] >> - org.apache.directory.api.ldap.codec.api.MessageEncoderException[WARNING] >> - >> org.apache.directory.api.ldap.codec.decorators.ModifyResponseDecorator[WARNING] >> - >> org.apache.directory.api.ldap.codec.controls.search.entryChange.EntryChangeGrammar$2[WARNING] >> - >> org.apache.directory.api.ldap.codec.decorators.SearchResultEntryDecorator[WARNING] >> - >> org.apache.directory.api.ldap.codec.actions.ldapResult.InitReferrals[WARNING] >> - >> org.apache.directory.api.ldap.codec.decorators.LdapResultDecorator[WARNING] >> - org.apache.directory.api.ldap.codec.LdapStatesEnum[WARNING] - 185 >> more...[WARNING] api-ldap-extras-codec-api-1.0.0-M20.jar, >> api-all-1.0.0-M20.jar define 44 overlapping classes: [WARNING] - >> org.apache.directory.api.ldap.extras.extended.CancelResponseImpl$1[WARNING] >> - >> org.apache.directory.api.ldap.extras.controls.ppolicy.PasswordPolicyResponseImpl[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.GracefulShutdownResponseImpl$1[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.GracefulShutdownRequest[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.PwdModifyResponseImpl[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.CertGenerationResponseImpl$1[WARNING] >> - org.apache.directory.api.ldap.extras.controls.SyncStateValue[WARNING] - >> org.apache.directory.api.ldap.extras.extended.StoredProcedureRequest[WARNING] >> - org.apache.directory.api.ldap.extras.extended.PwdModifyResponse[WARNING] >> - >> org.apache.directory.api.ldap.extras.extended.GracefulDisconnectResponse[WARNING] >> - 34 more...[WARNING] api-ldap-client-api-1.0.0-M20.jar, >> api-all-1.0.0-M20.jar define 32 overlapping classes: [WARNING] - >> org.apache.directory.ldap.client.api.Krb5LoginConfiguration[WARNING] - >> org.apache.directory.ldap.client.api.SaslPlainRequest[WARNING] - >> org.apache.directory.ldap.client.api.future.CompareFuture[WARNING] - >> org.apache.directory.ldap.client.api.LdapNetworkConnection$2[WARNING] - >> org.apache.directory.ldap.client.api.LdapNetworkConnection[WARNING] - >> org.apache.directory.ldap.client.api.SearchCursorImpl[WARNING] - >> org.apache.directory.ldap.client.api.exception.InvalidConnectionException[WARNING] >> - org.apache.directory.ldap.client.api.LdapConnectionConfig[WARNING] - >> org.apache.directory.ldap.client.api.PoolableLdapConnectionFactory[WARNING] >> - org.apache.directory.ldap.client.api.SaslRequest[WARNING] - 22 >> more...[WARNING] commons-beanutils-1.8.3.jar, commons-collections-3.2.2.jar >> define 10 overlapping classes: [WARNING] - >> org.apache.commons.collections.FastHashMap$EntrySet[WARNING] - >> org.apache.commons.collections.FastHashMap$KeySet[WARNING] - >> org.apache.commons.collections.FastHashMap$CollectionView$CollectionViewIterator[WARNING] >> - org.apache.commons.collections.ArrayStack[WARNING] - >> org.apache.commons.collections.FastHashMap$Values[WARNING] - >> org.apache.commons.collections.FastHashMap$CollectionView[WARNING] - >> org.apache.commons.collections.FastHashMap$1[WARNING] - >> org.apache.commons.collections.Buffer[WARNING] - >> org.apache.commons.collections.FastHashMap[WARNING] - >> org.apache.commons.collections.BufferUnderflowException[WARNING] >> api-ldap-extras-sp-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 2 overlapping >> classes: [WARNING] - >> org.apache.directory.api.ldap.sp.JavaStoredProcUtils[WARNING] - >> org.apache.directory.api.ldap.sp.LdapContextParameter[WARNING] >> api-all-1.0.0-M20.jar, api-ldap-extras-trigger-1.0.0-M20.jar define 32 >> overlapping classes: [WARNING] - >> org.apache.directory.api.ldap.trigger.AntlrTriggerSpecificationParserTokenTypes[WARNING] >> - org.apache.directory.api.ldap.trigger.TriggerSpecification[WARNING] - >> org.apache.directory.api.ldap.trigger.LdapOperation[WARNING] - >> org.apache.directory.api.ldap.trigger.StoredProcedureParameter$Add_ENTRY[WARNING] >> - >> org.apache.directory.api.ldap.trigger.ReusableAntlrTriggerSpecificationParser[WARNING] >> - >> org.apache.directory.api.ldap.trigger.StoredProcedureParameter$ModifyDN_ENTRY[WARNING] >> - >> org.apache.directory.api.ldap.trigger.StoredProcedureParameter$ModifyDN_NEW_RDN[WARNING] >> - org.apache.directory.api.ldap.trigger.TriggerUtils[WARNING] - >> org.apache.directory.api.ldap.trigger.StoredProcedureParameter$ModifyDN_NEW_SUPERIOR[WARNING] >> - >> org.apache.directory.api.ldap.trigger.ReusableAntlrTriggerSpecificationLexer[WARNING] >> - 22 more...[WARNING] apacheds-kerberos-codec-2.0.0-M15.jar, >> apacheds-protocol-kerberos-2.0.0-M15.jar define 2 overlapping classes: >> [WARNING] - >> org.apache.directory.server.kerberos.protocol.codec.KerberosEncoder[WARNING] >> - >> org.apache.directory.server.kerberos.protocol.codec.KerberosDecoder[WARNING] >> api-asn1-ber-1.0.0-M20.jar, api-all-1.0.0-M20.jar define 25 overlapping >> classes: [WARNING] - >> org.apache.directory.api.asn1.ber.tlv.UniversalTag[WARNING] - >> org.apache.directory.api.asn1.ber.tlv.LongDecoderException[WARNING] - >> org.apache.directory.api.asn1.ber.Asn1Decoder[WARNING] - >> org.apache.directory.api.asn1.ber.tlv.BooleanDecoder[WARNING] - >> org.apache.directory.api.asn1.ber.AbstractContainer[WARNING] - >> org.apache.directory.api.asn1.ber.grammar.GrammarAction[WARNING] - >> org.apache.directory.api.asn1.ber.tlv.LongDecoder[WARNING] - >> org.apache.directory.api.asn1.actions.AbstractReadBitString[WARNING] - >> org.apache.directory.api.asn1.ber.tlv.BooleanDecoderException[WARNING] - >> org.apache.directory.api.asn1.ber.tlv.BerValue[WARNING] - 15 >> more...[WARNING] api-ldap-extras-util-1.0.0-M20.jar, api-all-1.0.0-M20.jar >> define 4 overlapping classes: [WARNING] - >> org.apache.directory.api.ldap.util.JndiUtils[WARNING] - >> org.apache.directory.api.ldap.util.WrappedReferralException[WARNING] - >> org.apache.directory.api.ldap.util.WrappedPartialResultException[WARNING] - >> org.apache.directory.api.ldap.util.tree.DnNode[WARNING] maven-shade-plugin >> has detected that some class files are[WARNING] present in two or more JARs. >> When this happens, only one[WARNING] single version of the class is copied >> to the uber jar.[WARNING] Usually this is not harmful and you can skip these >> warnings,[WARNING] otherwise try to manually exclude artifacts based >> on[WARNING] mvn dependency:tree -Ddetail=true and the above output.[WARNING] >> See http://docs.codehaus.org/display/MAVENUSER/Shade+Plugin[INFO] Replacing >> original artifact with shaded artifact.[INFO] Replacing >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT.jar >> with >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/flink-yarn-tests_2.10-1.2-SNAPSHOT-shaded.jar[INFO] >> Dependency-reduced POM written at: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/dependency-reduced-pom.xml[INFO] >> [INFO] --- maven-javadoc-plugin:2.9.1:jar (attach-javadocs) @ >> flink-yarn-tests_2.10 ---[INFO] [INFO] --- maven-surefire-plugin:2.18.1:test >> (integration-tests) @ flink-yarn-tests_2.10 ---[INFO] Surefire report >> directory: >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/surefire-reports >> ------------------------------------------------------- T E S T >> S-------------------------------------------------------Running >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCaselog4j:ERROR Could >> not find value for key log4j.appender.testloggerlog4j:ERROR Could not >> instantiate appender named "testlogger".14:18:46,490 INFO >> org.apache.flink.yarn.YarnTestBase - Trying to >> locate uberjar in ..14:18:46,550 INFO org.apache.flink.yarn.YarnTestBase >> - Starting up MiniYARNClusterSep 04, 2016 2:18:48 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as >> a provider classSep 04, 2016 2:18:48 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root >> resource classSep 04, 2016 2:18:48 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider classSep >> 04, 2016 2:18:48 PM >> com.sun.jersey.server.impl.application.WebApplicationImpl _initiateINFO: >> Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'Sep >> 04, 2016 2:18:48 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.google.inject.servlet.GuiceFilter setPipelineWARNING: 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.Sep 04, 2016 2:18:49 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root >> resource classSep 04, 2016 2:18:49 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider classSep >> 04, 2016 2:18:49 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a >> provider classSep 04, 2016 2:18:49 PM >> com.sun.jersey.server.impl.application.WebApplicationImpl _initiateINFO: >> Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'Sep >> 04, 2016 2:18:49 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:49 >> PM com.google.inject.servlet.GuiceFilter setPipelineWARNING: 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.Sep 04, 2016 2:18:50 PM >> com.google.inject.servlet.InternalServletModule$BackwardsCompatibleServletContextProvider >> getWARNING: 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.Sep 04, 2016 2:18:50 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root >> resource classSep 04, 2016 2:18:50 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider classSep >> 04, 2016 2:18:50 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> registerINFO: Registering >> org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a >> provider classSep 04, 2016 2:18:50 PM >> com.sun.jersey.server.impl.application.WebApplicationImpl _initiateINFO: >> Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'Sep >> 04, 2016 2:18:50 PM >> com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:50 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.webapp.GenericExceptionHandler to >> GuiceManagedComponentProvider with the scope "Singleton"Sep 04, 2016 2:18:50 >> PM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory >> getComponentProviderINFO: Binding >> org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to >> GuiceManagedComponentProvider with the scope "Singleton"14:18:50,620 INFO >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase - >> ================================================================================Test >> >> testTaskManagerFailure(org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase) >> is >> running.--------------------------------------------------------------------------------14:18:50,722 >> INFO org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase - >> Starting testTaskManagerFailure()14:18:50,722 INFO >> org.apache.flink.yarn.YarnTestBase - Running with >> args [-j, >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/../build-target/lib/flink-dist_2.10-1.2-SNAPSHOT.jar, >> -t, >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/../build-target/lib, >> -n, 1, -jm, 768, -tm, 1024, -s, 3, -nm, customName, >> -Dfancy-configuration-value=veryFancy, -Dyarn.maximum-failed-containers=3, >> -Dyarn.containers.vcores=2]14:18:50,738 INFO >> org.apache.flink.yarn.YarnClusterDescriptor - Using >> values:14:18:50,740 INFO org.apache.flink.yarn.YarnClusterDescriptor >> - TaskManager count = 114:18:50,740 INFO >> org.apache.flink.yarn.YarnClusterDescriptor - JobManager >> memory = 76814:18:50,741 INFO org.apache.flink.yarn.YarnClusterDescriptor >> - TaskManager memory = 102414:18:50,791 WARN >> org.apache.flink.yarn.YarnClusterDescriptor - The file >> system scheme is 'file'. This indicates that the specified Hadoop >> configuration path is wrong and the system is using the default Hadoop >> configuration values.The Flink YARN client needs to store its files in a >> distributed file system14:18:50,815 WARN >> org.apache.flink.yarn.YarnClusterDescriptor - The >> configuration directory >> ('/workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/../build-target/conf') >> contains both LOG4J and Logback configuration files. Please delete or >> rename one of them.14:18:50,820 INFO org.apache.flink.yarn.Utils >> - Copying from >> file:/workspace/git-projects/vijikarthi/FLINK-3929/flink/build-target/conf/logback.xml >> to >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_0001/logback.xml14:18:50,829 >> INFO org.apache.flink.yarn.Utils - >> Copying from >> file:/workspace/git-projects/vijikarthi/FLINK-3929/flink/build-target/lib to >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_0001/lib14:18:50,969 >> INFO org.apache.flink.yarn.Utils - >> Copying from >> file:/workspace/git-projects/vijikarthi/FLINK-3929/flink/build-target/conf/log4j.properties >> to >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_0001/log4j.properties14:18:50,972 >> INFO org.apache.flink.yarn.Utils - >> Copying from >> file:/workspace/git-projects/vijikarthi/FLINK-3929/flink/build-target/lib/flink-dist_2.10-1.2-SNAPSHOT.jar >> to >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_0001/flink-dist_2.10-1.2-SNAPSHOT.jar14:18:51,093 >> INFO org.apache.flink.yarn.Utils - >> Copying from >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/build-target/conf/flink-conf.yaml >> to >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_0001/flink-conf.yaml14:18:51,133 >> INFO org.apache.flink.yarn.YarnClusterDescriptor - >> Submitting application master application_1473023926997_000114:18:51,266 >> INFO SecurityLogger.org.apache.hadoop.ipc.Server - Auth >> successful for appattempt_1473023926997_0001_000001 >> (auth:SIMPLE)14:18:51,377 INFO org.apache.flink.yarn.YarnClusterDescriptor >> - Waiting for the cluster to be allocated14:18:51,378 INFO >> org.apache.flink.yarn.YarnClusterDescriptor - Deploying >> cluster, current state ACCEPTED14:18:52,858 INFO >> SecurityLogger.org.apache.hadoop.ipc.Server - Auth >> successful for appattempt_1473023926997_0001_000001 >> (auth:SIMPLE)14:18:52,885 INFO org.apache.flink.yarn.YarnClusterDescriptor >> - YARN application has been deployed >> successfully.14:18:52,956 INFO org.apache.flink.yarn.YarnClusterClient >> - Starting client actor system.14:18:53,164 INFO >> akka.event.slf4j.Slf4jLogger - Slf4jLogger >> started14:18:53,197 INFO Remoting >> - Starting remoting14:18:53,300 INFO Remoting >> - Remoting started; listening on addresses >> :[akka.tcp://flink@137.69.172.169:38835]14:18:53,432 INFO >> org.apache.flink.yarn.YarnClusterClient - Start >> application client.14:18:53,440 INFO >> org.apache.flink.yarn.ApplicationClient - Notification >> about new leader address >> akka.tcp://flink@137.69.172.169:45364/user/jobmanager with session ID >> null.14:18:53,442 INFO org.apache.flink.yarn.ApplicationClient >> - Received address of new leader >> akka.tcp://flink@137.69.172.169:45364/user/jobmanager with session ID >> null.14:18:53,442 INFO org.apache.flink.yarn.ApplicationClient >> - Disconnect from JobManager null.14:18:53,444 INFO >> org.apache.flink.yarn.ApplicationClient - Trying to >> register at JobManager >> akka.tcp://flink@137.69.172.169:45364/user/jobmanager.14:18:53,452 INFO >> org.apache.flink.yarn.ApplicationClient - Successfully >> registered at the ResourceManager using JobManager >> Actor[akka.tcp://flink@137.69.172.169:45364/user/jobmanager#-1372246498]14:18:53,950 >> INFO SecurityLogger.org.apache.hadoop.ipc.Server - Auth >> successful for appattempt_1473023926997_0001_000001 >> (auth:SIMPLE)14:18:56,723 INFO org.apache.flink.yarn.YarnTestBase >> - Found expected output in redirected streams14:18:56,730 >> INFO org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase - Got >> application URL from YARN >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/14:18:56,730 >> INFO org.apache.flink.test.util.TestBaseUtils - >> Accessing URL >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/taskmanagers/ >> as URL: >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/taskmanagers/14:18:56,888 >> INFO org.apache.flink.test.util.TestBaseUtils - >> Accessing URL >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/jobmanager/config >> as URL: >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/jobmanager/config14:18:56,893 >> INFO org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase - >> Extracted hostname:port: 137.69.172.169 4536414:18:56,893 INFO >> org.apache.flink.test.util.TestBaseUtils - Accessing >> URL >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/jobmanager/log >> as URL: >> http://vijay-devbox:8088/proxy/application_1473023926997_0001/jobmanager/log14:20:30,724 >> WARN org.apache.flink.yarn.YarnTestBase - >> Interrupedjava.lang.InterruptedException: sleep interrupted at >> java.lang.Thread.sleep(Native Method) at >> org.apache.flink.yarn.YarnTestBase.sleep(YarnTestBase.java:351) at >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.testTaskManagerFailure(YARNSessionCapacitySchedulerITCase.java:288) >> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at >> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >> at java.lang.reflect.Method.invoke(Method.java:498) at >> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47) >> at >> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) >> at >> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44) >> at >> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) >> at >> org.junit.internal.runners.statements.FailOnTimeout$StatementThread.run(FailOnTimeout.java:74)14:20:31,247 >> ERROR org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase - >> --------------------------------------------------------------------------------Test >> >> testTaskManagerFailure(org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase) >> failed with:java.lang.Exception: test timed out after 100000 milliseconds >> at java.lang.Thread.sleep(Native Method) at >> org.apache.flink.yarn.YarnTestBase.sleep(YarnTestBase.java:351) at >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.testTaskManagerFailure(YARNSessionCapacitySchedulerITCase.java:288) >> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at >> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >> at java.lang.reflect.Method.invoke(Method.java:498) at >> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47) >> at >> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) >> at >> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44) >> at >> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) >> at >> org.junit.internal.runners.statements.FailOnTimeout$StatementThread.run(FailOnTimeout.java:74) >> ================================================================================14:20:31,259 >> INFO org.apache.flink.yarn.YarnTestBase - >> Stopping MiniYarn ClusterTests run: 1, Failures: 0, Errors: 1, Skipped: 0, >> Time elapsed: 118.278 sec <<< FAILURE! - in >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCasetestTaskManagerFailure(org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase) >> Time elapsed: 100.641 sec <<< ERROR!java.lang.Exception: test timed out >> after 100000 milliseconds at java.lang.Thread.sleep(Native Method) at >> org.apache.flink.yarn.YarnTestBase.sleep(YarnTestBase.java:351) at >> org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.testTaskManagerFailure(YARNSessionCapacitySchedulerITCase.java:288) >> 14:20:44,602 INFO org.apache.flink.yarn.YarnClusterClient >> - Shutting down YarnClusterClient from the client shutdown >> hook14:20:44,603 INFO org.apache.flink.yarn.YarnClusterClient >> - Sending shutdown request to the Application Master14:20:44,605 INFO >> org.apache.flink.yarn.ApplicationClient - Sending >> StopCluster request to JobManager.14:20:44,621 INFO >> org.apache.flink.yarn.YarnClusterClient - Deleted Yarn >> properties file at /tmp/.yarn-properties-vijay14:20:44,622 INFO >> org.apache.flink.yarn.YarnClusterClient - Deleting >> files in >> file:/tmp/junit573128047895399922/junit2952531703964950734/.flink/application_1473023926997_000114:20:44,896 >> INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - >> Stopping interactive command line interface, YARN cluster has been >> stopped.14:20:54,959 WARN akka.remote.ReliableDeliverySupervisor >> - Association with remote system >> [akka.tcp://flink@137.69.172.169:45364] has failed, address is now gated for >> [5000] ms. Reason is: [Disassociated]. >> Results : >> Tests in error: >> YARNSessionCapacitySchedulerITCase.testTaskManagerFailure:288->YarnTestBase.sleep:351 >> ยป >> Tests run: 1, Failures: 0, Errors: 1, Skipped: 0 >> [INFO] >> ------------------------------------------------------------------------[INFO] >> BUILD FAILURE[INFO] >> ------------------------------------------------------------------------[INFO] >> Total time: 02:44 min[INFO] Finished at: 2016-09-04T14:21:14-07:00[INFO] >> Final Memory: 106M/3670M[INFO] >> ------------------------------------------------------------------------[ERROR] >> Failed to execute goal >> org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test >> (integration-tests) on project flink-yarn-tests_2.10: There are test >> failures.[ERROR] [ERROR] Please refer to >> /workspace/git-projects/vijikarthi/FLINK-3929/flink/flink-yarn-tests/target/surefire-reports >> for the individual test results.[ERROR] -> [Help 1][ERROR] [ERROR] To see >> the full stack trace of the errors, re-run Maven with the -e switch.[ERROR] >> Re-run Maven using the -X switch to enable full debug logging.[ERROR] >> [ERROR] For more information about the errors and possible solutions, please >> read the following articles:[ERROR] [Help 1] >> http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException >> RegardsVijay >> >> >> On Sunday, September 4, 2016 1:20 AM, Robert Metzger >> <rmetz...@apache.org> wrote: >> >> >> Hi Vijay, >> >> are you seeing the issues on your local machine, or on Travis? >> Are the errors reproducible? >> >> Can you post the full stack trace here? >> >> Regards, >> Robert >> >> On Fri, Sep 2, 2016 at 6:24 PM, Vijay Srinivasaraghavan < >> vijikar...@yahoo.com> wrote: >> >>> Hello, >>> >>> I am seeing a "timeout" issue for one of the Yarn test case ( >>> YarnSessionCapacitySchedulerITCase>YarnTestBase.checkClusterEmpty) and >>> noticed similar references in FLINK-2213 (https://github.com/apache/ >>> flink/pull/1588) >>> >>> I have tested in latest mater code. Is anyone seeing this issue? >>> >>> Regards >>> Vijay >>> >> >> >> > >
