[ 
https://issues.apache.org/jira/browse/FLINK-7431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek closed FLINK-7431.
-----------------------------------
    Resolution: Cannot Reproduce

Closing because we haven't seen this in a while and also because it's tests for 
the legacy JobManager/TaskManager.

> test instability in JobManagerFailsITCase
> -----------------------------------------
>
>                 Key: FLINK-7431
>                 URL: https://issues.apache.org/jira/browse/FLINK-7431
>             Project: Flink
>          Issue Type: Improvement
>          Components: JobManager, Tests
>    Affects Versions: 1.4.0
>            Reporter: Nico Kruber
>            Priority: Blocker
>              Labels: test-stability
>             Fix For: 1.5.0
>
>
> In a branch with unrelated changes:
> {code}
> A TaskManager should go into a clean state in case of a JobManager 
> failure(org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase)  
> Time elapsed: 121.105 sec  <<< FAILURE!
> java.lang.AssertionError: assertion failed: timeout (119126026463 
> nanoseconds) during expectMsg while waiting for Acknowledge
>       at scala.Predef$.assert(Predef.scala:170)
>       at akka.testkit.TestKitBase$class.expectMsg_internal(TestKit.scala:338)
>       at akka.testkit.TestKitBase$class.expectMsg(TestKit.scala:315)
>       at akka.testkit.TestKit.expectMsg(TestKit.scala:718)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3$$anonfun$apply$mcV$sp$4.apply$mcV$sp(JobManagerFailsITCase.scala:118)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3$$anonfun$apply$mcV$sp$4.apply(JobManagerFailsITCase.scala:104)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3$$anonfun$apply$mcV$sp$4.apply(JobManagerFailsITCase.scala:104)
>       at akka.testkit.TestKitBase$class.within(TestKit.scala:296)
>       at akka.testkit.TestKit.within(TestKit.scala:718)
>       at akka.testkit.TestKitBase$class.within(TestKit.scala:310)
>       at akka.testkit.TestKit.within(TestKit.scala:718)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3.apply$mcV$sp(JobManagerFailsITCase.scala:104)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3.apply(JobManagerFailsITCase.scala:85)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase$$anonfun$1$$anonfun$apply$mcV$sp$3.apply(JobManagerFailsITCase.scala:85)
>       at 
> org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
>       at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
>       at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
>       at org.scalatest.Transformer.apply(Transformer.scala:22)
>       at org.scalatest.Transformer.apply(Transformer.scala:20)
>       at org.scalatest.WordSpecLike$$anon$1.apply(WordSpecLike.scala:953)
>       at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
>       at 
> org.apache.flink.api.scala.runtime.jobmanager.JobManagerFailsITCase.withFixture(JobManagerFailsITCase.scala:37)
> {code}
> https://travis-ci.org/NicoK/flink/jobs/263422429
> full logs: https://transfer.sh/bRKz7/399.4.tar.gz (unfortunately not much 
> more info there, as far as I can see)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to