Skip to content

Commit

Permalink
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -30,6 +30,7 @@
import org.apache.flink.runtime.testutils.WaitingCancelableInvokable;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import java.time.Duration;
@@ -67,6 +68,7 @@ void testJobCancelledIfClientHeartbeatTimeout() throws Exception {
}

@Test
@Disabled("Disable until FLINK-30629 is fixed.")
void testJobRunningIfClientReportHeartbeat() throws Exception {
JobClient jobClient = submitJob(createConfiguration(true));

0 comments on commit 9b5394a

Please sign in to comment.