flink
flink copied to clipboard
[FLINK-35193][table] Support drop materialized table syntax and execution in continuous refresh mode
What is the purpose of the change
Support drop materialized table syntax and execution in continuous refresh mode
Brief change log
- Support parser drop materialized table syntax in flink-sql-parser module
- Add DropMaterializedTableConverter for convert drop materialized table node to operations
- Support execution of drop materialized table
Verifying this change
- Added integration test for create and drop materialized table
- Add drop table operation in MaterializedTableStatementITCase after every test case finished
Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (no)
- The public API, i.e., is any changed class annotated with
@Public(Evolving): (no) - The serializers: (no)
- The runtime per-record code paths (performance sensitive): (no)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no)
- The S3 file system connector: (no)
Documentation
- Does this pull request introduce a new feature? (yes)
- If yes, how is the feature documented? (will be added in a separated pr)
CI report:
- ef94b24b264524cdfb1840aa91c73d5f3cc3631c Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:@flinkbot run azurere-run the last Azure build