Skip to content

Commit

Permalink
fix(BaseContainer): add ulimit
Browse files Browse the repository at this point in the history
  • Loading branch information
featherchen committed Oct 18, 2024
1 parent 639dfc8 commit 12feb14
Showing 1 changed file with 13 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,22 +18,15 @@
*/
package org.apache.gravitino.integration.test.container;

import static java.util.Objects.requireNonNull;
import static org.testcontainers.utility.MountableFile.forHostPath;

import com.github.dockerjava.api.DockerClient;
import com.github.dockerjava.api.command.InspectContainerResponse;
import com.github.dockerjava.api.model.ContainerNetwork;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import java.io.IOException;
import java.time.Duration;
import java.util.Collections;
import java.util.Map;
import static java.util.Objects.requireNonNull;
import java.util.Optional;
import java.util.Set;
import java.util.function.Consumer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.DockerClientFactory;
Expand All @@ -43,6 +36,15 @@
import org.testcontainers.containers.output.OutputFrame;
import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;
import org.testcontainers.containers.wait.strategy.Wait;
import static org.testcontainers.utility.MountableFile.forHostPath;

import com.github.dockerjava.api.DockerClient;
import com.github.dockerjava.api.command.InspectContainerResponse;
import com.github.dockerjava.api.model.ContainerNetwork;
import com.github.dockerjava.api.model.Ulimit;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;

/**
* The BaseContainer is the base for all containers. It's contains the common methods and settings
Expand Down Expand Up @@ -80,7 +82,8 @@ protected BaseContainer(
cmd.getHostConfig()
.withSysctls(
Collections.singletonMap(
"net.ipv4.ip_local_port_range", "20000 40000")));
"net.ipv4.ip_local_port_range", "20000 40000"))
.withUlimits(new Ulimit[] {new Ulimit("nproc", 120000L, 120000L)}));
this.ports = requireNonNull(ports, "ports is null");
this.hostName = requireNonNull(hostName, "hostName is null");
this.extraHosts = extraHosts;
Expand Down

0 comments on commit 12feb14

Please sign in to comment.