(flink-kubernetes-operator) branch main updated: [FLINK-36106][autoscaler] Clean up the t_flink_autoscaler_event_handler table after each test

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git


The following commit(s) were added to refs/heads/main by this push:
     new 84c1934d [FLINK-36106][autoscaler] Clean up the 
t_flink_autoscaler_event_handler table after each test
84c1934d is described below

commit 84c1934d6aca77ff98be78643cb724905724769e
Author: Rui Fan <1996fan...@gmail.com>
AuthorDate: Tue Aug 20 14:36:25 2024 +0800

    [FLINK-36106][autoscaler] Clean up the t_flink_autoscaler_event_handler 
table after each test
---
 .../autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java      | 3 ++-
 .../jdbc/testutils/databases/postgres/PostgreSQLExtension.java         | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java
 
b/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java
index 40c67a06..f0873a6f 100644
--- 
a/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java
+++ 
b/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java
@@ -34,7 +34,8 @@ class MySQLExtension implements BeforeAllCallback, 
AfterAllCallback, AfterEachCa
     private static final String DATABASE_NAME = "flink_autoscaler";
     private static final String USER_NAME = "root";
     private static final String PASSWORD = "123456";
-    private static final List<String> TABLES = 
List.of("t_flink_autoscaler_state_store");
+    private static final List<String> TABLES =
+            List.of("t_flink_autoscaler_state_store", 
"t_flink_autoscaler_event_handler");
 
     private final MySQLContainer<?> container;
 
diff --git 
a/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java
 
b/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java
index de4d6e37..ba4fd2f2 100644
--- 
a/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java
+++ 
b/flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java
@@ -34,7 +34,8 @@ class PostgreSQLExtension implements BeforeAllCallback, 
AfterAllCallback, AfterE
     private static final String DATABASE_NAME = "flink_autoscaler";
     private static final String USER_NAME = "root";
     private static final String PASSWORD = "123456";
-    private static final List<String> TABLES = 
List.of("t_flink_autoscaler_state_store");
+    private static final List<String> TABLES =
+            List.of("t_flink_autoscaler_state_store", 
"t_flink_autoscaler_event_handler");
 
     private final PostgreSQLContainer<?> container;