jackylau created FLINK-26732:
--------------------------------
Summary: 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
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)
