-
Notifications
You must be signed in to change notification settings - Fork 13k
New issue
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
[FLINK-29742][sql-gateway] Support completing statement in SqlGatewayService. #21141
Conversation
@flinkbot run azure |
1 similar comment
@flinkbot run azure |
cc @fsk119 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This PR also looks good to me!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for your contribution. I left some comments.
...-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java
Outdated
Show resolved
Hide resolved
04d96e1
to
fdfa3ce
Compare
fdfa3ce
to
16a3d26
Compare
Arrays.asList( | ||
"default_catalog.default_database.Table1", | ||
"default_catalog.default_database.Table2"); | ||
String incompleteSql = "SELECT * FROM Ta"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think we can inline incompleteSql and expectedTableHints.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Improved.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
…Service This closes apache#21141
…Service This closes apache#21141
What is the purpose of the change
Implement
SqlGatewayService#completeStatement
described in FLIP-91.Brief change log
(for example:)
SqlGatewayService#completeStatement
.testCompleteStatement
inSqlGatewayServiceITCase
.Verifying this change
This change added tests and can be verified as follows:
testCompleteStatement
inSqlGatewayServiceITCase
.Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: yesDocumentation