This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 04730cc63 [hotfix] Also deploy fluss-fs-hadoop (#1757)
add 68ce2256c [server] Improve the implementation of ALTER TABLE (#1760)
No new revisions were added by this update.
Summary of changes:
.../org/apache/fluss/client/admin/FlussAdmin.java | 13 +-
.../fluss/client/utils/ClientRpcMessageUtils.java | 21 ++++
.../utils/FlussTableChangeProtoConverter.java | 44 -------
.../fluss/client/admin/FlussAdminITCase.java | 11 +-
.../org/apache/fluss/config/FlussConfigUtils.java | 5 +
...leConfigsOpType.java => AlterConfigOpType.java} | 11 +-
.../org/apache/fluss/metadata/TableDescriptor.java | 15 +++
.../apache/fluss/flink/FlinkConnectorOptions.java | 8 ++
.../apache/fluss/flink/catalog/FlinkCatalog.java | 19 ++-
.../apache/fluss/flink/utils/FlinkConversions.java | 70 ++++++-----
.../utils/FlinkTableChangeToFlussTableChange.java | 52 --------
.../fluss/flink/catalog/FlinkCatalogITCase.java | 62 ++++++++--
.../org/apache/fluss/rpc/gateway/AdminGateway.java | 10 +-
.../org/apache/fluss/rpc/protocol/ApiKeys.java | 2 +-
fluss-rpc/src/main/proto/FlussApi.proto | 9 +-
.../server/coordinator/CoordinatorService.java | 76 ++----------
.../fluss/server/coordinator/MetadataManager.java | 133 +++++++--------------
.../fluss/server/entity/TablePropertyChanges.java | 93 ++++++++++++++
.../fluss/server/utils/ServerRpcMessageUtils.java | 61 ++++++++--
.../server/utils/TableDescriptorValidation.java | 60 ++++++----
.../server/coordinator/TableManagerITCase.java | 22 ++--
.../server/coordinator/TestCoordinatorGateway.java | 8 +-
.../server/testutils/RpcMessageTestUtils.java | 17 ++-
23 files changed, 450 insertions(+), 372 deletions(-)
delete mode 100644
fluss-client/src/main/java/org/apache/fluss/client/utils/FlussTableChangeProtoConverter.java
rename
fluss-common/src/main/java/org/apache/fluss/metadata/{AlterTableConfigsOpType.java
=> AlterConfigOpType.java} (79%)
delete mode 100644
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkTableChangeToFlussTableChange.java
create mode 100644
fluss-server/src/main/java/org/apache/fluss/server/entity/TablePropertyChanges.java
