You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by az...@apache.org on 2019/11/07 21:56:08 UTC
[flink] 17/21: fix LaunchableMesosWorkerTest
This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a commit to branch FLINK-13986-flip49-cleanup-e2e
in repository https://gitbox.apache.org/repos/asf/flink.git
commit dc0ba44b40fd86c1fb019f37383b849956125874
Author: Andrey Zagrebin <az...@apache.org>
AuthorDate: Mon Nov 4 18:31:06 2019 +0100
fix LaunchableMesosWorkerTest
---
.../flink/mesos/runtime/clusterframework/LaunchableMesosWorkerTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorkerTest.java b/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorkerTest.java
index 3d53160..42095b8 100644
--- a/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorkerTest.java
+++ b/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorkerTest.java
@@ -26,6 +26,7 @@ import org.apache.flink.mesos.scheduler.LaunchableTask;
import org.apache.flink.mesos.util.MesosResourceAllocation;
import org.apache.flink.mesos.util.MesosUtils;
import org.apache.flink.runtime.clusterframework.ContainerSpecification;
+import org.apache.flink.runtime.clusterframework.TaskExecutorResourceUtils;
import org.apache.flink.util.TestLogger;
import org.apache.mesos.Protos;
@@ -86,6 +87,7 @@ public class LaunchableMesosWorkerTest extends TestLogger {
configuration.setString(MesosOptions.MASTER_URL, "foobar");
final MemorySize memorySize = new MemorySize(1337L);
configuration.setString(TaskManagerOptions.LEGACY_MANAGED_MEMORY_SIZE, memorySize.toString());
+ TaskExecutorResourceUtils.adjustMemoryConfigurationForLocalExecution(configuration);
final LaunchableTask launchableTask = new LaunchableMesosWorker(
ignored -> Option.empty(),