This is an automated email from the ASF dual-hosted git repository.

panyuepeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 2eea63fe10d [FLINK-39158][runtime/test] Minor polish for 
RestAPIStabilityTestUtils to reduce redundant lines
2eea63fe10d is described below

commit 2eea63fe10dcf42fafea4e0a4333553ad538695e
Author: Yuepeng Pan <[email protected]>
AuthorDate: Wed Feb 25 21:57:45 2026 +0800

    [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to 
reduce redundant lines
---
 .../rest/compatibility/RestAPIStabilityTestUtils.java      | 14 +++-----------
 1 file changed, 3 insertions(+), 11 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTestUtils.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTestUtils.java
index 6ec5c8eee7a..90d1e3912f6 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTestUtils.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTestUtils.java
@@ -153,19 +153,11 @@ public final class RestAPIStabilityTestUtils {
 
         // check for entirely new calls, for which the snapshot should be 
updated
         for (final JsonNode curCall : cur.calls) {
-            final List<Tuple2<JsonNode, CompatibilityCheckResult>> 
compatibilityCheckResults =
-                    old.calls.stream()
-                            .map(
-                                    oldCall ->
-                                            Tuple2.of(
-                                                    curCall, 
checkCompatibility(oldCall, curCall)))
-                            .collect(Collectors.toList());
-
-            if (compatibilityCheckResults.stream()
+            if (old.calls.stream()
+                    .map(oldCall -> checkCompatibility(oldCall, curCall))
                     .noneMatch(
                             result ->
-                                    result.f1.getBackwardCompatibility()
-                                            == Compatibility.IDENTICAL)) {
+                                    result.getBackwardCompatibility() == 
Compatibility.IDENTICAL)) {
                 Assertions.fail(
                         "API was modified in a compatible way, but the 
snapshot was not updated. "
                                 + "To update the snapshot, re-run this test 
with -D"

Reply via email to