(flink) branch master updated: [FLINK-39711][runtime] Expose maxExceptions on exception message parameters

[snuyanzin]

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

snuyanzin 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 f8274080d47 [FLINK-39711][runtime] Expose maxExceptions on exception 
message parameters
f8274080d47 is described below

commit f8274080d47be0fb3583efacb0dace5e37c4f8ea
Author: Jubin Soni <jubinson...@gmail.com>
AuthorDate: Wed Jun 10 22:57:27 2026 -0700

    [FLINK-39711][runtime] Expose maxExceptions on exception message parameters
    
    
    ---------
    
    Co-authored-by: Jubin Soni <jubin.s...@yahooinc.com>
---
 .../job/JobExceptionsMessageParameters.java        |  2 +-
 .../job/JobExceptionsMessageParametersTest.java    | 54 ++++++++++++++++++++++
 2 files changed, 55 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParameters.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParameters.java
index 46e1d02716d..0bc350dfdbf 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParameters.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParameters.java
@@ -30,7 +30,7 @@ import java.util.Collections;
 /** {@link MessageParameters} for {@link JobExceptionsHandler}. */
 public class JobExceptionsMessageParameters extends JobMessageParameters {
 
-    private final UpperLimitExceptionParameter upperLimitExceptionParameter =
+    public final UpperLimitExceptionParameter upperLimitExceptionParameter =
             new UpperLimitExceptionParameter();
 
     private final FailureLabelFilterParameter failureLabelExceptionParameter =
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParametersTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParametersTest.java
new file mode 100644
index 00000000000..86219a0a2a2
--- /dev/null
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParametersTest.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.runtime.rest.messages.job;
+
+import org.apache.flink.api.common.JobID;
+import org.apache.flink.runtime.rest.messages.JobExceptionsHeaders;
+import org.apache.flink.runtime.rest.messages.MessageParameters;
+
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+/** Tests for {@link JobExceptionsMessageParameters}. */
+class JobExceptionsMessageParametersTest {
+
+    @Test
+    void testMaxExceptionsQueryParameterIsRendered() throws Exception {
+        JobID jobId = new JobID();
+        JobExceptionsMessageParameters parameters = new 
JobExceptionsMessageParameters();
+        parameters.jobPathParameter.resolve(jobId);
+        parameters.upperLimitExceptionParameter.resolveFromString("5");
+
+        String resolvedUrl = 
MessageParameters.resolveUrl(JobExceptionsHeaders.URL, parameters);
+
+        assertThat(resolvedUrl).isEqualTo("/jobs/" + jobId + 
"/exceptions?maxExceptions=5");
+    }
+
+    @Test
+    void testOptionalQueryParametersAreOmittedWhenUnresolved() {
+        JobID jobId = new JobID();
+        JobExceptionsMessageParameters parameters = new 
JobExceptionsMessageParameters();
+        parameters.jobPathParameter.resolve(jobId);
+
+        String resolvedUrl = 
MessageParameters.resolveUrl(JobExceptionsHeaders.URL, parameters);
+
+        assertThat(resolvedUrl).isEqualTo("/jobs/" + jobId + "/exceptions");
+    }
+}