[FLINK-36106][autoscaler] Clean up the t_flink_autoscaler_event_handl…

…er table after each test
apache · Aug 21, 2024 · 84c1934 · 84c1934
1 parent c8a6ca8
commit 84c1934
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/.../test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/mysql/MySQLExtension.java b/.../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/...va/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java b/...va/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;