You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/09/24 10:18:00 UTC

[jira] [Created] (FLINK-40790) DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification receives the first increment alone

Martijn Visser created FLINK-40790:
--------------------------------------

             Summary: DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification receives the first increment alone
                 Key: FLINK-40790
                 URL: https://issues.apache.org/jira/browse/FLINK-40790
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 2.4.0
            Reporter: Martijn Visser


https://github.com/apache/flink/actions/runs/35493621721/job/106033628963 (master push 2026-09-20, JDK 17, module core)

{code}
[ERROR] org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification -- Time elapsed: 0.333 s <<< FAILURE!
org.opentest4j.AssertionFailedError:
expected:
  [ResourceRequirement{resourceProfile=ResourceProfile{cpuCores=1.7, taskHeapMemory=0 bytes, taskOffHeapMemory=0 bytes, managedMemory=0 bytes, networkMemory=0 bytes}, numberOfRequiredSlots=3},
      ResourceRequirement{resourceProfile=ResourceProfile{cpuCores=0, taskHeapMemory=0 bytes, taskOffHeapMemory=0 bytes, managedMemory=100.000mb (104857600 bytes), networkMemory=0 bytes}, numberOfRequiredSlots=1}]
 but was:
  [ResourceRequirement{resourceProfile=ResourceProfile{cpuCores=1.7, taskHeapMemory=0 bytes, taskOffHeapMemory=0 bytes, managedMemory=0 bytes, networkMemory=0 bytes}, numberOfRequiredSlots=1}]
        at org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification(DefaultDeclarativeSlotPoolTest.java:88)
{code}

The merged expectation only applies to the slotRequestMaxInterval = 50 ms parameter, so this is that case: the two increaseResourceRequirementsBy calls were not batched into one notification.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)