You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by sh...@apache.org on 2022/07/15 03:24:06 UTC

[flink] branch master updated (d1e057a761a -> af9356c82ec)

This is an automated email from the ASF dual-hosted git repository.

shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from d1e057a761a [FLINK-28546][python][release] Add the release logic for py39 and m1 wheel package
     add af9356c82ec [FLINK-28053][sql-gateway] Introduce the operation lock to execute operation in sequence (#20149)

No new revisions were added by this update.

Summary of changes:
 .../gateway/service/context/SessionContext.java    |   4 +-
 .../table/gateway/service/operation/Operation.java | 160 ----------------
 .../service/operation/OperationManager.java        | 212 +++++++++++++++++++--
 .../gateway/service/result/ResultFetcher.java      |   3 +-
 .../table/gateway/service/session/Session.java     |   3 -
 .../gateway/service/SqlGatewayServiceITCase.java   | 129 ++++++++++++-
 6 files changed, 324 insertions(+), 187 deletions(-)
 delete mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/Operation.java