This is an automated email from the ASF dual-hosted git repository.
ron pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 86c8304d735 [FLINK-35041][test] Fix the
IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
add 9fe8d7bf870 [FLINK-35198][table] Support manual refresh materialized
table
No new revisions were added by this update.
Summary of changes:
.../MaterializedTableManager.java | 144 ++++++++++++-
.../service/MaterializedTableStatementITCase.java | 238 +++++++++++++++++++++
.../gateway/service/SqlGatewayServiceITCase.java | 30 +--
.../MaterializedTableManagerTest.java | 54 +++++
.../service/utils/SqlGatewayServiceTestUtil.java | 19 ++
.../sql/parser/ddl/SqlAlterMaterializedTable.java | 4 +
.../ddl/SqlAlterMaterializedTableRefresh.java | 10 +-
.../flink/table/operations/OperationUtils.java | 6 +-
.../AlterMaterializedTableRefreshOperation.java | 68 ++++++
...SqlAlterMaterializedTableRefreshConverter.java} | 31 ++-
.../operations/converters/SqlNodeConverters.java | 1 +
...erializedTableNodeToOperationConverterTest.java | 30 +++
12 files changed, 590 insertions(+), 45 deletions(-)
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManagerTest.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableRefreshOperation.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/{SqlAlterTableDropPartitionConverter.java
=> SqlAlterMaterializedTableRefreshConverter.java} (53%)
