You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:22:00 UTC
[jira] [Created] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP
Till Rohrmann created FLINK-25937:
-------------------------------------
Summary: SQL Client end-to-end test e2e fails on AZP
Key: FLINK-25937
URL: https://issues.apache.org/jira/browse/FLINK-25937
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination, Table SQL / API
Affects Versions: 1.15.0
Reporter: Till Rohrmann
The {{SQL Client end-to-end test}} e2e tests fails on AZP when using the {{AdaptiveScheduler}} because the scheduler expects that the parallelism is set for all vertices:
{code}
Feb 03 03:45:13 org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1609)
Feb 03 03:45:13 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
Feb 03 03:45:13 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
Feb 03 03:45:13 at java.lang.Thread.run(Thread.java:748)
Feb 03 03:45:13 Caused by: java.util.concurrent.CompletionException: java.lang.IllegalStateException: The adaptive scheduler expects the parallelism being set for each JobVertex (violated JobVertex: f74b775b58627a33e46b8c155b320255).
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606)
Feb 03 03:45:13 ... 3 more
Feb 03 03:45:13 Caused by: java.lang.IllegalStateException: The adaptive scheduler expects the parallelism being set for each JobVertex (violated JobVertex: f74b775b58627a33e46b8c155b320255).
Feb 03 03:45:13 at org.apache.flink.util.Preconditions.checkState(Preconditions.java:215)
Feb 03 03:45:13 at org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.assertPreconditions(AdaptiveScheduler.java:296)
Feb 03 03:45:13 at org.apache.flink.runtime.scheduler.adaptive.AdaptiveScheduler.<init>(AdaptiveScheduler.java:230)
Feb 03 03:45:13 at org.apache.flink.runtime.scheduler.adaptive.AdaptiveSchedulerFactory.createInstance(AdaptiveSchedulerFactory.java:122)
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:115)
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:345)
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:322)
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106)
Feb 03 03:45:13 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94)
Feb 03 03:45:13 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
Feb 03 03:45:13 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
Feb 03 03:45:13 ... 3 more
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30662&view=logs&j=fb37c667-81b7-5c22-dd91-846535e99a97&t=39a035c3-c65e-573c-fb66-104c66c28912&l=5782
--
This message was sent by Atlassian Jira
(v8.20.1#820001)