This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 9707b260a SubmitRequest checkBuildResult method optimization (#2867)
9707b260a is described below
commit 9707b260ad85dd735040502cd07c66c02b92c901
Author: ChengJie1053 <[email protected]>
AuthorDate: Fri Jul 21 08:50:54 2023 +0800
SubmitRequest checkBuildResult method optimization (#2867)
---
.../scala/org/apache/streampark/flink/client/bean/SubmitRequest.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 8f29a4cdf..5e627add8 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
@@ -175,7 +175,7 @@ case class SubmitRequest(
@throws[Exception]
def checkBuildResult(): Unit = {
executionMode match {
- case ExecutionMode.KUBERNETES_NATIVE_SESSION |
ExecutionMode.KUBERNETES_NATIVE_APPLICATION =>
+ case ExecutionMode.KUBERNETES_NATIVE_SESSION =>
if (buildResult == null) {
throw new Exception(
s"[flink-submit] current job: ${this.effectiveAppName} was not yet
built, buildResult is empty" +
