[FLINK-39310][web-ui] Use programArgsList in JSON body instead of program-args query parameter

The Web UI's jar.service.ts was using the deprecated program-args query
parameter (string) instead of sending programArgsList (string array) in
the JSON request body, which is incompatible with the Flink 2.0 REST API.

This change updates both runJob() and getPlan() to:
- Send parameters via JSON request body with correct field names matching
  JarRunRequestBody/JarRequestBody (entryClass, programArgsList,
  parallelism, savepointPath, allowNonRestoredState)
- Parse program arguments string into a string array (programArgsList)
  with proper handling of quoted arguments
- Switch getPlan() from GET with query params to POST with JSON body
- Fix pre-existing bug where savepointPath query param was incorrectly
  set to programArgs value instead of savepointPath
- Send parallelism as integer and allowNonRestoredState as boolean to
  match server-side types

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: daguimu

flink-runtime-web/web-dashboard/src/app/interfaces/jar.ts

@@ -22,6 +22,17 @@ export interface JarList {
   error?: boolean;
 }
 
+export interface JarPlanRequestBody {
+  entryClass?: string;
+  programArgsList?: string[];
+  parallelism?: number;
+}
+
+export interface JarRunRequestBody extends JarPlanRequestBody {
+  savepointPath?: string;
+  allowNonRestoredState?: boolean;
+}
+
 export interface JarFilesItem {
   id: string;
   name: string;

flink-runtime-web/web-dashboard/src/app/services/jar.service.ts

@@ -16,12 +16,20 @@
  * limitations under the License.
  */
 
-import { HttpClient, HttpEvent, HttpParams, HttpRequest } from '@angular/common/http';
+import { HttpClient, HttpEvent, HttpRequest } from '@angular/common/http';
 import { Injectable } from '@angular/core';
 import { Observable, of } from 'rxjs';
 import { catchError, map } from 'rxjs/operators';
 
-import { JarList, NodesItemCorrect, Plan, PlanDetail, VerticesLink } from '@flink-runtime-web/interfaces';
+import {
+  JarList,
+  JarPlanRequestBody,
+  JarRunRequestBody,
+  NodesItemCorrect,
+  Plan,
+  PlanDetail,
+  VerticesLink
+} from '@flink-runtime-web/interfaces';
 
 import { ConfigService } from './config.service';
 
@@ -64,40 +72,19 @@ export class JarService {
     savepointPath: string,
     allowNonRestoredState: string
   ): Observable<{ jobid: string }> {
-    const requestParam = { entryClass, parallelism, programArgs, savepointPath, allowNonRestoredState };
-    let params = new HttpParams();
-    if (entryClass) {
-      params = params.append('entry-class', entryClass);
-    }
-    if (parallelism) {
-      params = params.append('parallelism', parallelism);
-    }
-    if (programArgs) {
-      params = params.append('program-args', programArgs);
-    }
+    const requestBody: JarRunRequestBody = this.buildBaseRequestBody(entryClass, parallelism, programArgs);
     if (savepointPath) {
-      params = params.append('savepointPath', programArgs);
+      requestBody.savepointPath = savepointPath;
     }
     if (allowNonRestoredState) {
-      params = params.append('allowNonRestoredState', allowNonRestoredState);
+      requestBody.allowNonRestoredState = true;
     }
-    return this.httpClient.post<{ jobid: string }>(`${this.configService.BASE_URL}/jars/${jarId}/run`, requestParam, {
-      params
-    });
+    return this.httpClient.post<{ jobid: string }>(`${this.configService.BASE_URL}/jars/${jarId}/run`, requestBody);
   }
 
   public getPlan(jarId: string, entryClass: string, parallelism: string, programArgs: string): Observable<PlanDetail> {
-    let params = new HttpParams();
-    if (entryClass) {
-      params = params.append('entry-class', entryClass);
-    }
-    if (parallelism) {
-      params = params.append('parallelism', parallelism);
-    }
-    if (programArgs) {
-      params = params.append('program-args', programArgs);
-    }
-    return this.httpClient.get<Plan>(`${this.configService.BASE_URL}/jars/${jarId}/plan`, { params }).pipe(
+    const requestBody: JarPlanRequestBody = this.buildBaseRequestBody(entryClass, parallelism, programArgs);
+    return this.httpClient.post<Plan>(`${this.configService.BASE_URL}/jars/${jarId}/plan`, requestBody).pipe(
       map(data => {
         const links: VerticesLink[] = [];
         let nodes: NodesItemCorrect[] = [];
@@ -120,4 +107,49 @@ export class JarService {
       })
     );
   }
+
+  private buildBaseRequestBody(entryClass: string, parallelism: string, programArgs: string): JarPlanRequestBody {
+    const requestBody: JarPlanRequestBody = {};
+    if (entryClass) {
+      requestBody.entryClass = entryClass;
+    }
+    if (parallelism) {
+      requestBody.parallelism = parseInt(parallelism, 10);
+    }
+    if (programArgs) {
+      requestBody.programArgsList = this.parseArgs(programArgs);
+    }
+    return requestBody;
+  }
+
+  private parseArgs(programArgs: string): string[] {
+    const args: string[] = [];
+    let current = '';
+    let inSingleQuote = false;
+    let inDoubleQuote = false;
+    let hasQuote = false;
+
+    for (let i = 0; i < programArgs.length; i++) {
+      const char = programArgs[i];
+      if (char === "'" && !inDoubleQuote) {
+        inSingleQuote = !inSingleQuote;
+        hasQuote = true;
+      } else if (char === '"' && !inSingleQuote) {
+        inDoubleQuote = !inDoubleQuote;
+        hasQuote = true;
+      } else if (char === ' ' && !inSingleQuote && !inDoubleQuote) {
+        if (current.length > 0 || hasQuote) {
+          args.push(current);
+          current = '';
+          hasQuote = false;
+        }
+      } else {
+        current += char;
+      }
+    }
+    if (current.length > 0 || hasQuote) {
+      args.push(current);
+    }
+    return args;
+  }
 }