[flink] branch release-1.17 updated: [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase (#21892)

[sh...@apache.org]

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

shengkai pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.17 by this push:
     new 7cc2b4f35ea [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase (#21892)
7cc2b4f35ea is described below

commit 7cc2b4f35ea54c260365cdbc3e1ba92a06c5b112
Author: Ron <ld...@163.com>
AuthorDate: Thu Feb 9 10:32:50 2023 +0800

    [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase (#21892)
---
 flink-table/flink-sql-client/src/test/resources/sql/set.q | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/flink-table/flink-sql-client/src/test/resources/sql/set.q b/flink-table/flink-sql-client/src/test/resources/sql/set.q
index d375dc0845c..80e7ead6115 100644
--- a/flink-table/flink-sql-client/src/test/resources/sql/set.q
+++ b/flink-table/flink-sql-client/src/test/resources/sql/set.q
@@ -74,12 +74,17 @@ CREATE TABLE hive_table (
 [INFO] Execute statement succeed.
 !info
 
+SET table.dml-sync = true;
+[INFO] Execute statement succeed.
+!info
+
 # test "ctas" in Hive Dialect
 CREATE TABLE foo as select 1;
-[INFO] Submitting SQL update statement to the cluster...
-[INFO] SQL update statement has been successfully submitted to the cluster:
-Job ID:
+[INFO] Complete execution of the SQL update statement.
+!info
 
+RESET table.dml-sync;
+[INFO] Execute statement succeed.
 !info
 
 SELECT * from foo;