You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "jackylau (Jira)" <ji...@apache.org> on 2022/03/18 09:58:00 UTC
[jira] [Commented] (FLINK-26732) DefaultResourceAllocationStrategy need more log info to troubleshoot
[ https://issues.apache.org/jira/browse/FLINK-26732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17508687#comment-17508687 ]
jackylau commented on FLINK-26732:
----------------------------------
the info is not enough when the resource profiler requirement is not less than the TM total resource. then the resourcemanager will not allocate TM pod, then the job failed. user doesn't konw why.
> DefaultResourceAllocationStrategy need more log info to troubleshoot
> --------------------------------------------------------------------
>
> Key: FLINK-26732
> URL: https://issues.apache.org/jira/browse/FLINK-26732
> Project: Flink
> Issue Type: Improvement
> Components: Deployment / Kubernetes
> Affects Versions: 1.16.0
> Reporter: jackylau
> Priority: Major
> Fix For: 1.16.0
>
>
> {code:java}
> // code placeholder
> 2022-03-17 19:16:31,653 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job 0ffd9c39e3c91bbebbf5db350a0e0fa4: [ResourceRequirement{resourceProfile=ResourceProfile{cpuCores=0.13, taskHeapMemory=512.000mb (536870912 bytes), taskOffHeapMemory=32.000mb (33554432 bytes), managedMemory=0 bytes, networkMemory=0 bytes}, numberOfRequiredSlots=1}]2022-03-17 19:16:31,660 WARN org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Could not fulfill resource requirements of job 0ffd9c39e3c91bbebbf5db350a0e0fa4. Free slots: 02022-03-17 19:16:31,662 WARN org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge [] - Could not acquire the minimum required resources, failing slot requests. Acquired: []. Current slot pool status: Registered TMs: 0, registered slots: 0 free slots: 02022-03-17 19:16:31,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: TableSourceScan(table=[[default_catalog, default_database, datas... -> Sink: Sink(table=[default_catalog.default_database.sink], fields=[a, b]) (1/1) (327b64873d9098a9997d629320a683d1) switched from SCHEDULED to FAILED on [unassigned resource].org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources. {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)