diff --git a/flink-architecture-tests/flink-architecture-tests-base/src/main/java/org/apache/flink/architecture/common/Predicates.java b/flink-architecture-tests/flink-architecture-tests-base/src/main/java/org/apache/flink/architecture/common/Predicates.java index 056749c89ab00..1c5bd6de533a9 100644 --- a/flink-architecture-tests/flink-architecture-tests-base/src/main/java/org/apache/flink/architecture/common/Predicates.java +++ b/flink-architecture-tests/flink-architecture-tests-base/src/main/java/org/apache/flink/architecture/common/Predicates.java @@ -47,9 +47,7 @@ public static DescribedPredicate areDirectlyAnnotatedWithAtLeastOneOf Class... annotations) { return Arrays.stream(annotations) .map(CanBeAnnotated.Predicates::annotatedWith) - .reduce( - (canBeAnnotatedDescribedPredicate, other) -> - canBeAnnotatedDescribedPredicate.or(other)) + .reduce((p, pOther) -> p.or(pOther)) .orElseThrow(IllegalArgumentException::new) .forSubtype(); } @@ -60,10 +58,7 @@ public static DescribedPredicate areDirectlyAnnotatedWithAtLeastOneOf */ public static DescribedPredicate containAnyFieldsInClassHierarchyThat( DescribedPredicate predicate) { - return new ContainAnyFieldsThatPredicate<>( - "fields", - JavaClass::getAllFields, - predicate); + return new ContainAnyFieldsThatPredicate<>("fields", JavaClass::getAllFields, predicate); } /**