-
Notifications
You must be signed in to change notification settings - Fork 938
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
[WIP][KYUUBI #1352] Introduce FlinkSQLEngine infrastructure #1357
Conversation
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.
Please use spaces instead of tabs for indentation
Awesome~ |
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.
Java code still using TAB for indention, please covert to space, both 2 or 4 are fine
...uubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/WithFlinkSQLEngine.scala
Outdated
Show resolved
Hide resolved
...ql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
Outdated
Show resolved
Hide resolved
statement: String, | ||
runAsync: Boolean, | ||
queryTimeout: Long): Operation = { | ||
null |
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.
All of operations are stub now?
...ql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
Outdated
Show resolved
Hide resolved
Codecov Report
@@ Coverage Diff @@
## master #1357 +/- ##
============================================
- Coverage 59.38% 56.34% -3.04%
- Complexity 172 380 +208
============================================
Files 237 288 +51
Lines 12168 13727 +1559
Branches 1492 1551 +59
============================================
+ Hits 7226 7735 +509
- Misses 4331 5358 +1027
- Partials 611 634 +23
Continue to review full report at Codecov.
|
7df07a5
to
3e33762
Compare
Why are the changes needed?
How was this patch tested?
Add some test cases that check the changes thoroughly including negative and positive cases if possible
Add screenshots for manual tests if appropriate
Run test locally before make a pull request