You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/09 16:07:00 UTC

[jira] [Created] (FLINK-23341) AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

Roman Khachatryan created FLINK-23341:
-----------------------------------------

             Summary: AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure
                 Key: FLINK-23341
                 URL: https://issues.apache.org/jira/browse/FLINK-23341
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.14.0
            Reporter: Roman Khachatryan


https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=20241&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=05b74a19-4ee4-5036-c46f-ada307df6cf0&l=7650

{code}
Expected: is <false>
     but: was <true>
   at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
   at org.junit.Assert.assertThat(Assert.java:964)
   at org.junit.Assert.assertThat(Assert.java:930)
   at org.apache.flink.runtime.rpc.akka.AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminates AkkaRpcActor(AkkaRpcActorTest.java:375)
   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:59)
   at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
   at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
   at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
   at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
   at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
   at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
   at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
   at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
   at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
   at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
   at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
   at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
   at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
   at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
   at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
   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.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
   at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
   at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
   at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
   at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:238)
   at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:159)
   at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java :384)
{code}

bisect gives:
{code}
c47d8b92499fe25405c337be68907098309fd6c9 is the first bad commit
commit c47d8b92499fe25405c337be68907098309fd6c9
Author: Till Rohrmann <tr...@apache.org>
Date:   Thu Jul 1 13:38:32 2021 +0200

    [FLINK-23202][rpc] Fail rpc requests for unreachable recipients eagerly

    This commit adds the DeadLettersActor that monitor Akka's dead letter mailbox. Whenever a
    Flink Message is received if sends a failure to the sender to notify the sender about the
    unreachability of the recipient. That way it is possible to eagerly fail the result futures,
    and not having to wait on the rpc timeout.

{code}

cc: [~trohrmann]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)