diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/SavePointToKafkaTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/SavePointToKafkaTest.java index 9eb155bd5c7a..cad74721739a 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/SavePointToKafkaTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/SavePointToKafkaTest.java @@ -116,11 +116,6 @@ public void before() { LOGGER = nodeEngine.getLogger(AbstractSeaTunnelServerTest.class); } - @Test - public void testSavePointOnServerRestart() throws InterruptedException { - savePointAndRestore(true); - } - @Override public void after() { super.after();