This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit fa719938441bda7a6dc55339ad582812df95ecf8 Author: Chesnay Schepler <[email protected]> AuthorDate: Tue Jun 14 13:42:11 2022 +0200 [hotfix][tests] Streamline SubmissionBufferingTaskManagerGateway --- .../apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java index 65c7b0c33f9..4d8db038d0a 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java @@ -1559,7 +1559,7 @@ public class AdaptiveSchedulerTest extends TestLogger { public SubmissionBufferingTaskManagerGateway(int capacity) { submittedTasks = new ArrayBlockingQueue<>(capacity); - super.setSubmitConsumer(submittedTasks::offer); + setSubmitConsumer(ignored -> {}); } @Override
