azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime]
TaskExecutor derive and register with default slot resource profile
URL: https://github.com/apache/flink/pull/10146#discussion_r351839963
##########
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java
##########
@@ -107,8 +107,6 @@ public static MesosTaskManagerParameters
createTmParameters(Configuration config
final MesosTaskManagerParameters taskManagerParameters =
MesosTaskManagerParameters.create(configuration);
final TaskExecutorResourceSpec taskExecutorResourceSpec =
taskManagerParameters.containeredParameters().getTaskExecutorResourceSpec();
- log.info("TaskManagers will be created with {} task slots",
-
taskManagerParameters.containeredParameters().numSlots());
Review comment:
I think complete removal of this log (or better to say change to log default
fraction instead of number of slots) belongs to the next commits. Here we can
substitute `taskManagerParameters.containeredParameters().numSlots()` also with
`configuration.getInteger(MESOS_RM_TASKS_SLOTS)`
----------------------------------------------------------------
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]
With regards,
Apache Git Services
