We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Expose the query operator as Flink SQL client done for the select query.
query like this
select sum(a) ,count(*) from sou
before this feature(data return as duplicate, make user confuse) +--------------+---------+------------+ | EXPR$0 | EXPR$1 | +--------------+---------+------------+ | -1861035379 | 1 | | -1861035379 | 1 | | -317406356 | 2 | | -317406356 | 2 | | -684766290 | 3 | | -684766290 | 3 |
after (as flink sql client table SET 'sql-client.execution.result-mode' = 'changelog'; setting ) +--------------+---------+------------+ | EXPR$0 | EXPR$1 | op | +--------------+---------+------------+ | -1861035379 | 1 | +I | | -1861035379 | 1 | -U | | -317406356 | 2 | +U | | -317406356 | 2 | -U | | -684766290 | 3 | +U | | -684766290 | 3 | -U |
The concept of changelog is specific to Flink SQL. If the operation is not exposed, users will be confused when using JDBC/Beeline.
No response
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Code of Conduct
Search before asking
Describe the feature
which feature we need
Expose the query operator as Flink SQL client done for the select query.
query like this
before this feature(data return as duplicate, make user confuse)
+--------------+---------+------------+
| EXPR$0 | EXPR$1 |
+--------------+---------+------------+
| -1861035379 | 1 |
| -1861035379 | 1 |
| -317406356 | 2 |
| -317406356 | 2 |
| -684766290 | 3 |
| -684766290 | 3 |
after (as flink sql client table SET 'sql-client.execution.result-mode' = 'changelog'; setting )
+--------------+---------+------------+
| EXPR$0 | EXPR$1 | op |
+--------------+---------+------------+
| -1861035379 | 1 | +I |
| -1861035379 | 1 | -U |
| -317406356 | 2 | +U |
| -317406356 | 2 | -U |
| -684766290 | 3 | +U |
| -684766290 | 3 | -U |
Motivation
why is nessary ?
The concept of changelog is specific to Flink SQL. If the operation is not exposed, users will be confused when using JDBC/Beeline.
Describe the solution
Additional context
No response
Are you willing to submit PR?
The text was updated successfully, but these errors were encountered: