[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438647311 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImplTest.java ## @@ -0,0 +1,245 @@ +/* + *

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438644325 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTracker.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438643603 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,204 @@ +/* + * Licensed

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r438636756 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,204 @@ +/* + * Licensed

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-10 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r437926403 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTracker.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-10 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r437918968 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -447,12 +452,40 @@ public void

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-05 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435880917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-04 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435366834 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-04 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435232158 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java ## @@ -91,6 +92,20 @@

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-04 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435232158 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java ## @@ -91,6 +92,20 @@

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-04 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435231056 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-02 Thread GitBox
azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r431914289 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulk.java ## @@ -0,0 +1,59 @@ +/* + *