This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 5b637243f27 [FLINK-29618][yarn-tests] Remove Timeout annotation in
YARN-related integration tests
5b637243f27 is described below
commit 5b637243f27063f3a2f5fbc46a9e0d87207ff37a
Author: Wencong Liu <[email protected]>
AuthorDate: Fri May 12 10:52:55 2023 +0800
[FLINK-29618][yarn-tests] Remove Timeout annotation in YARN-related
integration tests
---
.../test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java | 4 ----
.../src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java | 2 --
.../test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java | 3 ---
.../src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java | 2 --
4 files changed, 11 deletions(-)
diff --git
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
index 92504a59910..debe53616dc 100644
---
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
+++
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
@@ -68,7 +68,6 @@ import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.io.TempDir;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -151,7 +150,6 @@ class YARNHighAvailabilityITCase extends YarnTestBase {
* Tests that Yarn will restart a killed {@link
YarnSessionClusterEntrypoint} which will then
* resume a persisted {@link JobGraph}.
*/
- @Timeout(value = 30, unit = TimeUnit.MINUTES)
@Test
void testKillYarnSessionClusterEntrypoint() throws Exception {
runTest(
@@ -189,7 +187,6 @@ class YARNHighAvailabilityITCase extends YarnTestBase {
});
}
- @Timeout(value = 30, unit = TimeUnit.MINUTES)
@Test
void testJobRecoversAfterKillingTaskManager() throws Exception {
runTest(
@@ -215,7 +212,6 @@ class YARNHighAvailabilityITCase extends YarnTestBase {
* Tests that we can retrieve an HA enabled cluster by only specifying the
application id if no
* other high-availability.cluster-id has been configured. See FLINK-20866.
*/
- @Timeout(value = 30, unit = TimeUnit.MINUTES)
@Test
void testClusterClientRetrieval() throws Exception {
runTest(
diff --git
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
index 8c19fd17e35..efff8dfa7b9 100644
---
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
+++
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
@@ -37,7 +37,6 @@ import
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoSchedule
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.Timeout;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -81,7 +80,6 @@ class YARNSessionFIFOITCase extends YarnTestBase {
ensureNoProhibitedStringInLogFiles(PROHIBITED_STRINGS,
WHITELISTED_STRINGS);
}
- @Timeout(value = 60)
@Test
void testDetachedMode() throws Exception {
runTest(() -> runDetachedModeTest(Collections.emptyMap()));
diff --git
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
index e2685f09a2e..5e944d3f8b8 100644
---
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
+++
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
@@ -38,7 +38,6 @@ import
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoSchedule
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -124,7 +123,6 @@ class YARNSessionFIFOSecuredITCase extends
YARNSessionFIFOITCase {
SecureTestEnvironment.cleanup();
}
- @Timeout(value = 60)
@Test
void testDetachedModeSecureWithPreInstallKeytab() throws Exception {
runTest(
@@ -153,7 +151,6 @@ class YARNSessionFIFOSecuredITCase extends
YARNSessionFIFOITCase {
});
}
- @Timeout(value = 60)
@Test
@Override
void testDetachedMode() throws Exception {
diff --git
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
index f5473fab912..6728c541ce8 100644
---
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
+++
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
@@ -47,7 +47,6 @@ import org.apache.hadoop.yarn.client.api.YarnClient;
import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.assertj.core.data.Offset;
import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.Timeout;
import java.io.File;
import java.net.URI;
@@ -65,7 +64,6 @@ class YarnConfigurationITCase extends YarnTestBase {
private static final Time TIMEOUT = Time.seconds(10L);
/** Tests that the Flink components are started with the correct memory
settings. */
- @Timeout(value = 60)
@Test
void testFlinkContainerMemory() throws Exception {
runTest(