beam-builds mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #337
Date Thu, 03 Jan 2019 16:07:23 GMT
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/337/display/redirect?page=changes>

Changes:

[echauchot] split SerializablePipelineOptions into serialization utils and instance

------------------------------------------
[...truncated 35.32 MB...]
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code PAssert$25/GroupGlobally/GatherAllOutputs/GroupByKey
-> [6]PAssert$25/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering,
FlattenDummyAndContents, NeverTrigger} (4/16) (ac1d813cdff5db6ecf269cb7d01f2464).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$25/GroupGlobally/{Create.Values, WindowIntoDummy, RemoveDummyTriggering,
FlattenDummyAndContents, NeverTrigger} (10/16) (1034bf3b3731221daa0bfd1c29cf3eab).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$25/GroupGlobally/{Create.Values, WindowIntoDummy, RemoveDummyTriggering,
FlattenDummyAndContents, NeverTrigger} (10/16) (1034bf3b3731221daa0bfd1c29cf3eab) switched
from RUNNING to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$25/GroupGlobally/{Create.Values, WindowIntoDummy, RemoveDummyTriggering,
FlattenDummyAndContents, NeverTrigger} (10/16) (1034bf3b3731221daa0bfd1c29cf3eab).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally PAssert$25/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$25/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (cf8801480c8e1dc8dfce90eee6fbb96c).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- PAssert$25/GroupGlobally/GroupDummyAndContents -> [5]PAssert$25/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions} (4/16) (cf8801480c8e1dc8dfce90eee6fbb96c) switched from RUNNING
to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code PAssert$25/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$25/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (cf8801480c8e1dc8dfce90eee6fbb96c).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [6]Create.TimestampedValues/{Create.Values, ParDo(ConvertTimestamps)} -> ([2]{Values,
Combine.globally(Composed)} -> ToKeyedWorkItem, ToKeyedWorkItem) (4/16) (ac786f59ef746c91ca67195f1a6d1d20).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [6]Create.TimestampedValues/{Create.Values, ParDo(ConvertTimestamps)} -> ([2]{Values,
Combine.globally(Composed)} -> ToKeyedWorkItem, ToKeyedWorkItem) (4/16) (ac786f59ef746c91ca67195f1a6d1d20)
switched from RUNNING to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [6]Create.TimestampedValues/{Create.Values, ParDo(ConvertTimestamps)} -> ([2]{Values,
Combine.globally(Composed)} -> ToKeyedWorkItem, ToKeyedWorkItem) (4/16) (ac786f59ef746c91ca67195f1a6d1d20).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally PAssert$24/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$24/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (1c983ae82f0dcea5f9f670a6ea507c4a).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- PAssert$24/GroupGlobally/GroupDummyAndContents -> [5]PAssert$24/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions} (4/16) (1c983ae82f0dcea5f9f670a6ea507c4a) switched from RUNNING
to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code PAssert$24/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$24/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (1c983ae82f0dcea5f9f670a6ea507c4a).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally [4]Combine.globally(Composed)/CreateVoid/Read(CreateSource)/{ParDo(SplitBoundedSource),
Reshuffle.ViaRandomKey} -> ToKeyedWorkItem (15/16) (e8bafcaf79d5879df15f3ed85636a4bf).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- [4]Combine.globally(Composed)/CreateVoid/Read(CreateSource)/{ParDo(SplitBoundedSource),
Reshuffle.ViaRandomKey} -> ToKeyedWorkItem (15/16) (e8bafcaf79d5879df15f3ed85636a4bf) switched
from RUNNING to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code [4]Combine.globally(Composed)/CreateVoid/Read(CreateSource)/{ParDo(SplitBoundedSource),
Reshuffle.ViaRandomKey} -> ToKeyedWorkItem (15/16) (e8bafcaf79d5879df15f3ed85636a4bf).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally Combine.globally(Composed)/ProduceDefault/ParMultiDo(Anonymous)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#c7d03f4f65d170f0
-> Map (4/16) (215a8eef5067254fab504a9e2324dba2).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Combine.globally(Composed)/ProduceDefault/ParMultiDo(Anonymous)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#c7d03f4f65d170f0
-> Map (4/16) (215a8eef5067254fab504a9e2324dba2) switched from RUNNING to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:495)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
    	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id
7d0f7ba33a3359ef23185403fd1e77d3 timed out.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1609)
    	... 15 more
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Triggering cancellation of task code Combine.globally(Composed)/ProduceDefault/ParMultiDo(Anonymous)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#c7d03f4f65d170f0
-> Map (4/16) (215a8eef5067254fab504a9e2324dba2).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to fail task externally PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$24/GroupGlobally/{Create.Values, WindowIntoDummy, RemoveDummyTriggering,
FlattenDummyAndContents, NeverTrigger} (4/16) (438c07cf2b958d47ec62cde1b9a1372a).
    [flink-akka.actor.default-dispatcher-491] INFO org.apache.flink.runtime.taskmanager.Task
- PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$24/GroupGlobally/{Create.Values, WindowIntoDummy, RemoveDummyTriggering,
FlattenDummyAndContents, NeverTrigger} (4/16) (438c07cf2b958d47ec62cde1b9a1372a) switched
from RUNNING to FAILED.
    org.apache.flink.util.FlinkException: JobManager responsible for d7c07e345be2b961c0f55f6de797c69e
lost the leadership.
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor.access$1200(TaskExecutor.java:136)
    	at org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$notifyHeartbeatTimeout$0(TaskExecutor.java:1608)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
    	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
    	at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
    	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@47b9fea6.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation
method: stop()].
	at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
	at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
	at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
	at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
	at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
	at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 1' finished
with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
	at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
	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.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
	... 10 more

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput SKIPPED

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine SKIPPED

36 tests completed, 1 failed, 4 skipped

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for
':' Thread 6,5,main]) completed. Took 51 mins 40.546 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
  This problem might be caused by incorrect test process configuration.
  Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log
output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 54m 13s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/nqrzcdunfuaxo

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org


Mime
View raw message