(incubator-streampark) branch dev-2.1.2 updated: [Improve] DELETE|UPDATE statement minor improvement

[be...@apache.org]

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

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


The following commit(s) were added to refs/heads/dev-2.1.2 by this push:
     new 8d292d70b [Improve] DELETE|UPDATE statement minor improvement
8d292d70b is described below

commit 8d292d70be686225a0a6b9e9d8086702754710a4
Author: benjobs <be...@gmail.com>
AuthorDate: Sun Oct 29 14:16:15 2023 +0800

    [Improve] DELETE|UPDATE statement minor improvement
---
 .../scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala
index 51e498eb7..58b0f6747 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkSqlExecutor.scala
@@ -126,7 +126,10 @@ object FlinkSqlExecutor extends Logger {
               throw new RuntimeException("StreamPark dose not support 'select' statement now!")
             case DELETE | UPDATE =>
               if (runMode == "STREAMING") {
-                throw new UnsupportedOperationException(s"$command unsupported streaming mode.")
+                throw new UnsupportedOperationException(
+                  s"Currently, ${command.toUpperCase()} statement only supports in batch mode, " +
+                    s"and it requires the target table connector implements the SupportsRowLevelDelete, " +
+                    s"For more details please refer to: https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/$command")
               }
             case _ =>
               try {