You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2021/09/14 07:58:02 UTC
[flink] branch release-1.13 updated: [FLINK-22889][tests] Increase
timeouts in JdbcExactlyOnceSinkE2eTest
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new cf78dc6 [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest
cf78dc6 is described below
commit cf78dc6e6ad8c14ba4f98a777f931eced3f5018d
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Tue Sep 7 02:36:45 2021 +0200
[FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest
...to tolerate occasional long XA PREPARE executions in MySQL.
---
.../flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java
index 0a8cc8c..eda30ae 100644
--- a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java
+++ b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java
@@ -62,6 +62,7 @@ import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;
@@ -81,6 +82,7 @@ import static org.apache.flink.configuration.TaskManagerOptions.TASK_CANCELLATIO
import static org.apache.flink.connector.jdbc.JdbcTestFixture.INPUT_TABLE;
import static org.apache.flink.connector.jdbc.JdbcTestFixture.INSERT_TEMPLATE;
import static org.apache.flink.connector.jdbc.xa.JdbcXaFacadeTestHelper.getInsertedIds;
+import static org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions.CHECKPOINTING_TIMEOUT;
import static org.apache.flink.util.Preconditions.checkArgument;
import static org.apache.flink.util.Preconditions.checkState;
import static org.junit.Assert.assertTrue;
@@ -92,6 +94,9 @@ public class JdbcExactlyOnceSinkE2eTest extends JdbcTestBase {
private static final Logger LOG = LoggerFactory.getLogger(JdbcExactlyOnceSinkE2eTest.class);
+ private static final long CHECKPOINT_TIMEOUT_MS = 20_000L;
+ private static final long TASK_CANCELLATION_TIMEOUT_MS = 20_000L;
+
private interface JdbcExactlyOnceSinkTestEnv {
void start();
@@ -141,7 +146,8 @@ public class JdbcExactlyOnceSinkE2eTest extends JdbcTestBase {
// restart all tasks if at least one fails
configuration.set(EXECUTION_FAILOVER_STRATEGY, "full");
// cancel tasks eagerly to reduce the risk of running out of memory with many restarts
- configuration.set(TASK_CANCELLATION_TIMEOUT, 1000L);
+ configuration.set(TASK_CANCELLATION_TIMEOUT, TASK_CANCELLATION_TIMEOUT_MS);
+ configuration.set(CHECKPOINTING_TIMEOUT, Duration.ofMillis(CHECKPOINT_TIMEOUT_MS));
cluster =
new MiniClusterWithClientResource(
new MiniClusterResourceConfiguration.Builder()