diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/TagActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/TagActionITCase.java
index de48a1252f67..f2cd9744c853 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/TagActionITCase.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/TagActionITCase.java
@@ -40,10 +40,14 @@
 /** IT cases for tag management actions. */
 public class TagActionITCase extends ActionITCaseBase {
 
+    protected void initReadWriteEnvironment() throws Exception {
+        init(warehouse);
+    }
+
     @ParameterizedTest(name = "{0}")
     @ValueSource(strings = {"action", "action_job", "procedure_indexed", "procedure_named"})
     public void testCreateAndDeleteTag(String invoker) throws Exception {
-        init(warehouse);
+        initReadWriteEnvironment();
 
         RowType rowType =
                 RowType.of(
@@ -253,7 +257,7 @@ public void testCreateAndDeleteTag(String invoker) throws Exception {
     @ParameterizedTest(name = "{0}")
     @ValueSource(strings = {"action", "action_job", "procedure_indexed", "procedure_named"})
     public void testRenameTag(String invoker) throws Exception {
-        init(warehouse);
+        initReadWriteEnvironment();
 
         RowType rowType =
                 RowType.of(
@@ -354,7 +358,7 @@ public void testRenameTag(String invoker) throws Exception {
     @ParameterizedTest(name = "{0}")
     @ValueSource(strings = {"action", "action_job", "procedure_indexed", "procedure_named"})
     public void testCreateLatestTag(String invoker) throws Exception {
-        init(warehouse);
+        initReadWriteEnvironment();
 
         RowType rowType =
                 RowType.of(