This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5b60aba2ecb [FLINK-40000][runtime/test] Remove the redundant testing
util class SynchronousComponentMainThreadExecutor (#28481)
new 64775b024b0 [FLINK-39999][table] Make Flink Sql calls unparsable as it
is required by Calcite 1.42.0
new 1c17615d998 [FLINK-39999][table] Add temporary
DeepCopyUnparsingTesterImpl before Calcite 1.42.0 upgrade
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/sql/parser/SqlPartitionSpecProperty.java | 13 +-
.../org/apache/flink/sql/parser/SqlProperty.java | 10 +-
.../org/apache/flink/sql/parser/ddl/SqlAddJar.java | 11 +-
.../flink/sql/parser/ddl/SqlAddPartitions.java | 42 +++++-
.../flink/sql/parser/ddl/SqlAlterDatabase.java | 11 +-
.../flink/sql/parser/ddl/SqlAlterFunction.java | 31 ++++-
.../flink/sql/parser/ddl/SqlCompilePlan.java | 16 ++-
.../flink/sql/parser/ddl/SqlCreateDatabase.java | 21 ++-
.../flink/sql/parser/ddl/SqlCreateFunction.java | 35 ++++-
.../flink/sql/parser/ddl/SqlDistribution.java | 26 +++-
.../flink/sql/parser/ddl/SqlDropDatabase.java | 25 +++-
.../flink/sql/parser/ddl/SqlDropFunction.java | 27 +++-
.../flink/sql/parser/ddl/SqlDropPartitions.java | 35 ++++-
.../apache/flink/sql/parser/ddl/SqlRemoveJar.java | 10 +-
.../flink/sql/parser/ddl/SqlReplaceTableAs.java | 46 +++++-
.../org/apache/flink/sql/parser/ddl/SqlReset.java | 9 +-
.../org/apache/flink/sql/parser/ddl/SqlSet.java | 13 +-
.../apache/flink/sql/parser/ddl/SqlStopJob.java | 19 ++-
.../flink/sql/parser/ddl/SqlTableColumn.java | 65 ++++++++-
.../flink/sql/parser/ddl/SqlTableOption.java | 9 +-
.../flink/sql/parser/ddl/SqlUseDatabase.java | 9 +-
.../apache/flink/sql/parser/ddl/SqlUseModules.java | 14 +-
.../apache/flink/sql/parser/ddl/SqlWatermark.java | 9 +-
.../sql/parser/ddl/catalog/SqlAlterCatalog.java | 10 +-
.../parser/ddl/catalog/SqlAlterCatalogComment.java | 20 +++
.../parser/ddl/catalog/SqlAlterCatalogOptions.java | 20 +++
.../parser/ddl/catalog/SqlAlterCatalogReset.java | 20 +++
.../sql/parser/ddl/catalog/SqlCreateCatalog.java | 21 ++-
.../sql/parser/ddl/catalog/SqlDropCatalog.java | 21 ++-
.../sql/parser/ddl/catalog/SqlUseCatalog.java | 9 +-
.../ddl/connection/SqlAlterConnectionRename.java | 28 +++-
.../ddl/connection/SqlAlterConnectionReset.java | 28 +++-
.../ddl/connection/SqlAlterConnectionSet.java | 28 +++-
.../parser/ddl/connection/SqlCreateConnection.java | 25 +++-
.../parser/ddl/connection/SqlDropConnection.java | 27 +++-
.../parser/ddl/constraint/SqlTableConstraint.java | 21 ++-
.../SqlAlterMaterializedTableAsQuery.java | 20 +++
.../SqlAlterMaterializedTableDistribution.java | 37 +++++
.../SqlAlterMaterializedTableDropDistribution.java | 21 +++
.../SqlAlterMaterializedTableFreshness.java | 20 +++
.../SqlAlterMaterializedTableOptions.java | 20 +++
.../SqlAlterMaterializedTableRefresh.java | 20 +++
.../SqlAlterMaterializedTableRefreshMode.java | 22 ++-
.../SqlAlterMaterializedTableReset.java | 20 +++
.../SqlAlterMaterializedTableResume.java | 20 +++
.../SqlAlterMaterializedTableSchema.java | 126 +++++++++++++++++
.../SqlAlterMaterializedTableSuspend.java | 20 +++
.../SqlCreateMaterializedTable.java | 59 +++++++-
.../SqlCreateOrAlterMaterializedTable.java | 44 +++++-
.../SqlDropMaterializedTable.java | 15 +-
.../parser/ddl/materializedtable/SqlStartMode.java | 10 ++
.../sql/parser/ddl/model/SqlAlterModelRename.java | 26 +++-
.../sql/parser/ddl/model/SqlAlterModelReset.java | 26 +++-
.../sql/parser/ddl/model/SqlAlterModelSet.java | 26 +++-
.../flink/sql/parser/ddl/model/SqlCreateModel.java | 26 +++-
.../sql/parser/ddl/model/SqlCreateModelAs.java | 25 +++-
.../flink/sql/parser/ddl/model/SqlDropModel.java | 24 +++-
.../ddl/position/SqlTableColumnPosition.java | 12 +-
.../flink/sql/parser/ddl/resource/SqlResource.java | 9 +-
.../sql/parser/ddl/table/SqlAlterTableAdd.java | 31 +++++
.../ddl/table/SqlAlterTableDistribution.java | 35 +++++
.../sql/parser/ddl/table/SqlAlterTableDrop.java | 100 ++++++++++++-
.../ddl/table/SqlAlterTableDropDistribution.java | 25 +++-
.../sql/parser/ddl/table/SqlAlterTableModify.java | 31 +++++
.../sql/parser/ddl/table/SqlAlterTableOptions.java | 30 +++-
.../sql/parser/ddl/table/SqlAlterTableRename.java | 28 +++-
.../ddl/table/SqlAlterTableRenameColumn.java | 29 +++-
.../sql/parser/ddl/table/SqlAlterTableReset.java | 28 +++-
.../sql/parser/ddl/table/SqlAlterTableSchema.java | 4 +-
.../sql/parser/ddl/table/SqlAnalyzeTable.java | 20 ++-
.../flink/sql/parser/ddl/table/SqlCreateTable.java | 32 ++++-
.../sql/parser/ddl/table/SqlCreateTableAs.java | 33 ++++-
.../sql/parser/ddl/table/SqlCreateTableLike.java | 34 ++++-
.../flink/sql/parser/ddl/table/SqlDropTable.java | 25 +++-
.../flink/sql/parser/ddl/table/SqlTableLike.java | 34 ++++-
.../flink/sql/parser/ddl/view/SqlAlterViewAs.java | 21 +++
.../parser/ddl/view/SqlAlterViewProperties.java | 20 +++
.../sql/parser/ddl/view/SqlAlterViewRename.java | 21 +++
.../flink/sql/parser/ddl/view/SqlCreateView.java | 23 ++-
.../flink/sql/parser/ddl/view/SqlDropView.java | 25 +++-
.../apache/flink/sql/parser/dml/RichSqlInsert.java | 39 ++++++
.../flink/sql/parser/dml/SqlBeginStatementSet.java | 9 +-
.../sql/parser/dml/SqlCompileAndExecutePlan.java | 12 +-
.../flink/sql/parser/dml/SqlEndStatementSet.java | 10 +-
.../apache/flink/sql/parser/dml/SqlExecute.java | 9 +-
.../flink/sql/parser/dml/SqlExecutePlan.java | 11 +-
.../flink/sql/parser/dml/SqlStatementSet.java | 13 +-
.../flink/sql/parser/dml/SqlTruncateTable.java | 9 +-
.../flink/sql/parser/dql/SqlDescribeCatalog.java | 15 +-
.../flink/sql/parser/dql/SqlDescribeDatabase.java | 15 +-
.../flink/sql/parser/dql/SqlDescribeJob.java | 9 +-
.../apache/flink/sql/parser/dql/SqlLoadModule.java | 10 +-
.../sql/parser/dql/SqlRichDescribeConnection.java | 16 ++-
.../sql/parser/dql/SqlRichDescribeFunction.java | 16 ++-
.../flink/sql/parser/dql/SqlRichDescribeModel.java | 16 ++-
.../flink/sql/parser/dql/SqlRichDescribeTable.java | 16 ++-
.../flink/sql/parser/dql/SqlRichExplain.java | 24 +++-
.../apache/flink/sql/parser/dql/SqlShowCall.java | 32 ++++-
.../flink/sql/parser/dql/SqlShowCatalogs.java | 15 +-
.../flink/sql/parser/dql/SqlShowColumns.java | 16 ++-
.../flink/sql/parser/dql/SqlShowConnections.java | 15 +-
.../flink/sql/parser/dql/SqlShowCreateCatalog.java | 10 +-
.../sql/parser/dql/SqlShowCreateConnection.java | 10 +-
.../parser/dql/SqlShowCreateMaterializedTable.java | 20 ++-
.../flink/sql/parser/dql/SqlShowCreateModel.java | 10 +-
.../flink/sql/parser/dql/SqlShowCreateTable.java | 10 +-
.../flink/sql/parser/dql/SqlShowCreateView.java | 10 +-
.../sql/parser/dql/SqlShowCurrentCatalog.java | 9 +-
.../sql/parser/dql/SqlShowCurrentDatabase.java | 9 +-
.../flink/sql/parser/dql/SqlShowDatabases.java | 21 ++-
.../flink/sql/parser/dql/SqlShowFunctions.java | 28 +++-
.../apache/flink/sql/parser/dql/SqlShowJars.java | 9 +-
.../apache/flink/sql/parser/dql/SqlShowJobs.java | 9 +-
.../apache/flink/sql/parser/dql/SqlShowModels.java | 15 +-
.../flink/sql/parser/dql/SqlShowModules.java | 11 +-
.../flink/sql/parser/dql/SqlShowPartitions.java | 10 +-
.../flink/sql/parser/dql/SqlShowProcedures.java | 17 ++-
.../apache/flink/sql/parser/dql/SqlShowTables.java | 37 ++++-
.../flink/sql/parser/dql/SqlUnloadModule.java | 9 +-
.../sql/parser/DeepCopyUnparsingTesterImpl.java | 155 +++++++++++++++++++++
.../flink/sql/parser/FlinkSqlParserImplTest.java | 14 ++
.../flink/sql/parser/FlinkSqlUnParserTest.java | 2 +-
.../MaterializedTableStatementUnParserTest.java | 3 +-
123 files changed, 2664 insertions(+), 152 deletions(-)
create mode 100644
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/DeepCopyUnparsingTesterImpl.java
