revert ci

apache · Sep 20, 2023 · 9eaf6fc · 9eaf6fc
1 parent bbac948
commit 9eaf6fc
Showing 1 changed file with 4 additions and 12 deletions.
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
@@ -57,9 +57,10 @@ public class Db2E2eITCase extends FlinkContainerTestEnvironment {
     private static final Path mysqlDriverJar = TestUtils.getResource("mysql-driver.jar");
 
     public static final String DB2_IMAGE = "ibmcom/db2";
+    public static final String DB2_CUSTOM_IMAGE = "custom/db2-cdc:1.4";
     private static final DockerImageName DEBEZIUM_DOCKER_IMAGE_NAME =
             DockerImageName.parse(
-                            new ImageFromDockerfile("custom/db2-cdc:1.4")
+                            new ImageFromDockerfile(DB2_CUSTOM_IMAGE)
                                     .withDockerfile(getFilePath("docker/db2/Dockerfile"))
                                     .get())
                     .asCompatibleSubstituteFor(DB2_IMAGE);
@@ -116,17 +117,8 @@ public void after() {
     @AfterClass
     public static void afterClass() {
         // Cleanup the db2 image, because it's too large and will cause the next test to fail.
-        db2Container
-                .getDockerClient()
-                .listImagesCmd()
-                .withImageNameFilter(DB2_IMAGE)
-                .exec()
-                .forEach(
-                        image ->
-                                db2Container
-                                        .getDockerClient()
-                                        .removeImageCmd(image.getId())
-                                        .exec());
+        db2Container.getDockerClient().removeImageCmd(DB2_CUSTOM_IMAGE).exec();
+        db2Container.getDockerClient().removeImageCmd(DB2_IMAGE).exec();
     }
 
     @Test