Checkpoint 60 - Fix java8 usage of Optional from isEmpty to !isPresent

voonhous · voonhous · commit 249fa2b228ae · 2025-11-21T15:49:23.000+08:00
diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java
@@ -804,7 +804,7 @@ public void waitUntilJobState(JobID jobId, Duration timeout, JobStatus expectedS
             Optional<JobStatusMessage> optMessage =
                     jobStatusMessages.stream().filter(j -> j.getJobId().equals(jobId)).findFirst();
 
-            if (optMessage.isEmpty()) {
+            if (!optMessage.isPresent()) {
                 LOG.warn("Job: {} not found, waiting for the next loop...", jobId);
                 continue;
             }

Original file line number	Diff line number	Diff line change
`@@ -804,7 +804,7 @@ public void waitUntilJobState(JobID jobId, Duration timeout, JobStatus expectedS`
`804`	`804`	`Optional<JobStatusMessage> optMessage =`
`805`	`805`	`jobStatusMessages.stream().filter(j -> j.getJobId().equals(jobId)).findFirst();`
`806`	`806`
`807`		`- if (optMessage.isEmpty()) {`
	`807`	`+ if (!optMessage.isPresent()) {`
`808`	`808`	`LOG.warn("Job: {} not found, waiting for the next loop...", jobId);`
`809`	`809`	`continue;`
`810`	`810`	`}`