[
https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458510#comment-17458510
]
Yun Gao commented on FLINK-25269:
---------------------------------
Hi [~mapohl] very thanks for taking care of this issue! It seems the job is in
fact run successfully and the test failed due to find error logs in the flink
log directory, but the exception seems to be a false alarm since it is caused
by that the ResourceManager is started after JM tries to connect to it for the
first time~
> Quickstarts Scala nightly end-to-end test failed on azure due to could not
> connect to resource manager
> ------------------------------------------------------------------------------------------------------
>
> Key: FLINK-25269
> URL: https://issues.apache.org/jira/browse/FLINK-25269
> Project: Flink
> Issue Type: Bug
> Components: Build System / Azure Pipelines
> Affects Versions: 1.15.0
> Reporter: Yun Gao
> Priority: Major
> Labels: test-stability
>
> {code:java}
> Dec 10 13:12:17 at akka.actor.Actor.aroundReceive(Actor.scala:537)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> [flink-rpc-akka_ae8961cc-571e-483d-b468-da652db90bb9.jar:1.15-SNAPSHOT]
> Dec 10 13:12:17 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_292]
> Dec 10 13:12:17 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> [?:1.8.0_292]
> Dec 10 13:12:17 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> [?:1.8.0_292]
> Dec 10 13:12:17 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> [?:1.8.0_292]
> Dec 10 13:12:17 2021-12-10 13:12:07,296 INFO
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
> Starting the resource manager.
> Dec 10 13:12:17 2021-12-10 13:12:09,426 INFO
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
> Registering TaskManager with ResourceID 10.1.0.79:35275-d26a40
> (akka.tcp://[email protected]:35275/user/rpc/taskmanager_0) at ResourceManager
> Dec 10 13:12:17 2021-12-10 13:12:09,496 INFO
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
> Registering TaskManager with ResourceID 10.1.0.79:35275-d26a40
> (akka.tcp://[email protected]:35275/user/rpc/taskmanager_0) at ResourceManager
> Dec 10 13:12:17 2021-12-10 13:12:13,189 INFO
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Received
> JobGraph submission 'Elasticsearch7.x end to end sink test example'
> (effb86be1cfd961e947988200a724de7).
> Dec 10 13:12:17 2021-12-10 13:12:13,190 INFO
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Submitting
> job 'Elasticsearch7.x end to end sink test example'
> (effb86be1cfd961e947988200a724de7).
> Dec 10 13:12:17 2021-12-10 13:12:13,225 INFO
> org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting
> RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at
> akka://flink/user/rpc/jobmanager_2 .
> Dec 10 13:12:17 2021-12-10 13:12:13,252 INFO
> org.apache.flink.runtime.jobmaster.JobMaster [] -
> Initializing job 'Elasticsearch7.x end to end sink test example'
> (effb86be1cfd961e947988200a724de7).
> Dec 10 13:12:17 2021-12-10 13:12:13,324 INFO
> org.apache.flink.runtime.jobmaster.JobMaster [] - Using
> restart back off time strategy
> FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=2147483647,
> backoffTimeMS=1000) for Elasticsearch7.x end to end sink test example
> (effb86be1cfd961e947988200a724de7).
> Dec 10 13:12:17 2021-12-10 13:12:13,428 INFO
> org.apache.flink.runtime.jobmaster.JobMaster [] - Running
> initialization on master for job Elasticsearch7.x end to end sink test
> example (effb86be1cfd961e947988200a724de7).
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27953&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a&l=3408
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
