fsk119 commented on a change in pull request #15340:
URL: https://github.com/apache/flink/pull/15340#discussion_r599563910
##########
File path: flink-table/flink-sql-client/src/test/resources/sql/select.q
##########
@@ -50,8 +50,38 @@ java.lang.IllegalArgumentException: testing elements of
values source shouldn't
# (we can't test changelog mode and table mode in IT case)
# ==========================================================================
+SET table.dml-sync=true;
+[INFO] Session property has been set.
+!info
+
+create table MyTable (
+ id int,
+ str string
+) with (
+ 'connector' = 'filesystem',
+ 'path' = '$VAR_PATH',
+ 'format' = 'csv'
+);
+[INFO] Table has been created.
+!info
+
+SELECT id, COUNT(*) as cnt, COUNT(DISTINCT str) as uv
+FROM MyTable
+GROUP BY id;
++----+-------------+----------------------+----------------------+
+| op | id | cnt | uv |
++----+-------------+----------------------+----------------------+
+Received a total of 0 row
+!ok
+
+INSERT INTO MyTable SELECT * FROM (VALUES (1, 'Hello World'), (2, 'Hi'), (2,
'Hi'), (3, 'Hello'), (3, 'World'), (4, 'ADD'), (5, 'LINE'));
+[INFO] Submitting SQL update statement to the cluster...
+[INFO] Table update statement has been successfully submitted to the cluster:
+
Review comment:
In beeline, hive doesn't have any warning or info...
Sounds good to print messages to info users.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
