From 472369614394bf0b450a46de31df15e43fa9e377 Mon Sep 17 00:00:00 2001
From: Scott Sandre <scott.sandre@databricks.com>
Date: Tue, 20 Jun 2023 15:27:58 -0700
Subject: [PATCH] done

---
 .../io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java b/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java
index 330936168a0..ff1c82da671 100644
--- a/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java
+++ b/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java
@@ -468,7 +468,7 @@ private List<String> getDeltaCheckpointFiles(String deltaTablePath) throws IOExc
             return stream
                 .filter(file -> !Files.isDirectory(file))
                 .map(file -> file.getFileName().toString())
-                .filter(fileName -> !fileName.endsWith(".json"))
+                .filter(fileName -> fileName.endsWith(".checkpoint.parquet"))
                 .collect(Collectors.toList());
         }
     }