revert ci

apache · Sep 20, 2023 · b7325f9 · b7325f9
1 parent 9eaf6fc
commit b7325f9
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/Db2E2eITCase.java b/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/Db2E2eITCase.java
@@ -118,7 +118,17 @@ public void after() {
     public static void afterClass() {
         // Cleanup the db2 image, because it's too large and will cause the next test to fail.
         db2Container.getDockerClient().removeImageCmd(DB2_CUSTOM_IMAGE).exec();
-        db2Container.getDockerClient().removeImageCmd(DB2_IMAGE).exec();
+        db2Container
+                .getDockerClient()
+                .listImagesCmd()
+                .withImageNameFilter(DB2_IMAGE)
+                .exec()
+                .forEach(
+                        image ->
+                                db2Container
+                                        .getDockerClient()
+                                        .removeImageCmd(image.getId())
+                                        .exec());
     }
 
     @Test