rmetzger commented on a change in pull request #15262:
URL: https://github.com/apache/flink/pull/15262#discussion_r598507289
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
##########
@@ -1026,6 +1026,9 @@ public TestingJobManagerRunner createJobManagerRunner(
private Tuple2<JobGraph, BlockingJobVertex> getBlockingJobGraphAndVertex()
{
final BlockingJobVertex blockingJobVertex = new
BlockingJobVertex("testVertex");
blockingJobVertex.setInvokableClass(NoOpInvokable.class);
+ // the parallelism has to be set for the AdaptiveScheduler to not fail
Review comment:
```suggestion
// AdaptiveScheduler expects the parallelism to be set for each
vertex
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
