-
Notifications
You must be signed in to change notification settings - Fork 13.3k
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-32219][sql-client] Fix SqlClient hangs when executing EXECUTE PLAN statement #22703
Conversation
@fsk119, could you help to review the fix when you're available? |
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 fix. I left some minor suggestions.
...ateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java
Outdated
Show resolved
Hide resolved
...ateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java
Outdated
Show resolved
Hide resolved
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
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
…PLAN statement (apache#22703) (cherry picked from commit 83ba6b5)
* [FLINK-32396][jdbc-driver] Support timestamp and timestamp_ltz for jdbc driver… * [FLINK-33000][sql-gateway] SqlGatewayServiceITCase should utilize… * [FLINK-33000][sql-gateway] OperationManagerTest should utilize… * [FLINK-33000][sql-gateway] ResultFetcherTest should utilize… * [FLINK-32219][sql-client] Fix SqlClient hangs when executing EXECUTE PLAN statement (apache#22703) * [FLINK-31956][table] Extend COMPILE PLAN statement to read/write from/to Flink FileSystem * [FLINK-32661][sql-gateway] Fix unstable OperationRelatedITCase.testOperationRelatedApis * [FLINK-32512][table] Don't register resource to user resource manager when… * [FLINK-32309][sql-gateway] Use independent resource manager for table environment (apache#22768) * fix * [FLINK-32299][gateway] Upload python jar when sql contains python udf jar * [FLINK-31956][table-planner] Fix COMPILE PLAN statement fails to write to file… https://code.byted.org/inf/flink/merge_requests/5796
What is the purpose of the change
This PR fixes the issue that the
COMPILE AND EXECUTE PLAN
orEXECUTE PLAN
statement causes the SQL client to hang forever. The reason is thatOperationExecutor
didn't take these two kinds of operation kind into account. Instead, they should be dealt with likeModifyOperation
.Brief change log
OperationExecutor
cope withExecutionPlanOperation
andCompileAndExecutePlanOperation
.TableEnvironmentImpl
should applyTABLE_DML_SYNC
for bothModifyOpeartion
andExecutePlanOperation
. Both of them are compiled frominsert into
queries.Verifying this change
insert.q
to verify that theEXECUTE PLAN
andCOMPILE AND EXECUTE PLAN
statements work as expected after the fix.EXECUTE PLAN
statement.Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: noDocumentation