diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java index 85e7fad75..b9daf2e17 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java @@ -92,13 +92,6 @@ public static GenericContainer createDorisContainer() { new GenericContainer<>(DORIS_DOCKER_IMAGE) .withNetwork(Network.newNetwork()) .withNetworkAliases("DorisContainer") - .withEnv("FE_SERVERS", "fe1:127.0.0.1:9010") - .withEnv("FE_ID", "1") - .withEnv("CURRENT_BE_IP", "127.0.0.1") - .withEnv("CURRENT_BE_PORT", "9050") - .withCommand("ulimit -n 65536") - .withCreateContainerCmdModifier( - cmd -> cmd.getHostConfig().withMemorySwap(0L)) .withPrivilegedMode(true) .withLogConsumer( new Slf4jLogConsumer( @@ -149,7 +142,6 @@ protected static void printClusterStatus() throws Exception { LOG.info("Current machine IP: {}", InetAddress.getLocalHost()); echo("sh", "-c", "cat /proc/cpuinfo | grep 'cpu cores' | uniq"); echo("sh", "-c", "free -h"); - echo("sh", "-c", "top -n 1"); try (Connection connection = DriverManager.getConnection( String.format(URL, DORIS_CONTAINER.getHost()), USERNAME, PASSWORD);