(incubator-streampark) branch k8s_deploy_shutdown updated: [Improve] minor improvement

[benjobs]

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

benjobs pushed a commit to branch k8s_deploy_shutdown
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/k8s_deploy_shutdown by this 
push:
     new a9455cf79 [Improve] minor improvement
a9455cf79 is described below

commit a9455cf7938205e776f53b1895e9dc402b18fb34
Author: benjobs <benj...@gmail.com>
AuthorDate: Thu Jan 11 22:13:46 2024 +0800

    [Improve] minor improvement
---
 .../scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
index 1d7725fbb..96afd4b08 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala
@@ -66,7 +66,7 @@ case class SubmitRequest(
     @Nullable k8sSubmitParam: KubernetesSubmitParam,
     @Nullable extraParameter: JavaMap[String, Any]) {
 
-  lazy val appProperties: Map[String, String] = 
getParameterMap(KEY_FLINK_PROPERTY_PREFIX)
+  private lazy val appProperties: Map[String, String] = 
getParameterMap(KEY_FLINK_PROPERTY_PREFIX)
 
   lazy val appOption: Map[String, String] = 
getParameterMap(KEY_FLINK_OPTION_PREFIX)
 
@@ -80,7 +80,7 @@ case class SubmitRequest(
 
   lazy val flinkSQL: String = extraParameter.get(KEY_FLINK_SQL()).toString
 
-  lazy val allowNonRestoredState = Try(
+  lazy val allowNonRestoredState: Boolean = Try(
     
properties.get(SavepointConfigOptions.SAVEPOINT_IGNORE_UNCLAIMED_STATE.key).toString.toBoolean)
     .getOrElse(false)