You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tr...@apache.org on 2021/02/04 11:30:02 UTC

[flink] branch master updated (bad43aa -> b0549d4)

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from bad43aa  [FLINK-20894][table-api] Introduce SupportsAggregatePushDown interface
     add 729c4dd  [FLINK-21078] Make TestingDeclarativeSlotPoolFactory a top-level class
     add 3336bba  [FLINK-21078] Add DeclarativeSlotPoolService which encapsulates a DeclarativeSlotPool
     add b0549d4  [FLINK-21078] Make DeclarativeSlotPoolService a parent of DeclarativeSlotPoolBridge

No new revisions were added by this update.

Summary of changes:
 .../slotpool/DeclarativeSlotPoolBridge.java        | 259 ++++------------
 .../slotpool/DeclarativeSlotPoolService.java       | 313 +++++++++++++++++++
 ...java => DeclarativeSlotPoolServiceFactory.java} |  27 +-
 ...ativeSlotPoolBridgeResourceDeclarationTest.java |   6 +-
 .../slotpool/DeclarativeSlotPoolBridgeTest.java    |  21 --
 .../slotpool/DeclarativeSlotPoolServiceTest.java   | 334 +++++++++++++++++++++
 .../TestingDeclarativeSlotPoolFactory.java}        |  19 +-
 7 files changed, 725 insertions(+), 254 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{DeclarativeSlotPoolBridgeServiceFactory.java => DeclarativeSlotPoolServiceFactory.java} (62%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolServiceTest.java
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPoolFactory.java => test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingDeclarativeSlotPoolFactory.java} (75%)