[
https://issues.apache.org/jira/browse/FLINK-26732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692583#comment-17692583
]
Weijie Guo commented on FLINK-26732:
------------------------------------
Hi [~jackylau], I just feel a little confused. From the log we can see that
the slotManager is {{DeclarativeSlotManager}}, but the title is `add log to
{{DefaultResourceAllocationStrategy}}`. IIUC, this allocation strategy will
only be created for {{FineGrainedSlotManager}}.
> 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
> Labels: pull-request-available
> Fix For: 1.17.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.10#820010)
