This is an automated email from the ASF dual-hosted git repository.
lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5bbdc469d7f [FLINK-32523][test] Increase the tolerable checkpoint
failure number to avoid aborting after job failing for
NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted
add 84044f45830 [FLINK-32860][flink-table-api] Add missing visibility
annotation for Table APIs
No new revisions were added by this update.
Summary of changes:
.../flink-architecture-tests-production/README.md | 2 +-
.../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 1 +
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 12 +++---
.../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 50 ++++++----------------
.../flink/architecture/rules/TableApiRules.java | 47 ++++++++++++++++++++
.../org/apache/flink/table/sinks/CsvTableSink.java | 1 +
.../apache/flink/table/sources/CsvTableSource.java | 2 +
.../internal/ExecutableOperationContextImpl.java | 2 +
.../table/api/internal/TablePipelineImpl.java | 2 +
.../flink/table/api/internal/TableResultImpl.java | 1 +
.../flink/table/api/internal/TableResultUtils.java | 2 +
.../flink/table/catalog/AbstractCatalogTable.java | 2 +
.../flink/table/catalog/AbstractCatalogView.java | 2 +
.../flink/table/catalog/CatalogDatabaseImpl.java | 3 ++
.../flink/table/catalog/CatalogFunctionImpl.java | 2 +
.../apache/flink/table/catalog/CatalogManager.java | 1 +
.../flink/table/catalog/CatalogPartitionImpl.java | 3 ++
.../flink/table/catalog/FileCatalogStore.java | 2 +
.../table/catalog/FileCatalogStoreFactory.java | 2 +
.../catalog/FileCatalogStoreFactoryOptions.java | 2 +
.../flink/table/catalog/FunctionCatalog.java | 1 +
.../table/catalog/GenericInMemoryCatalog.java | 2 +
.../catalog/GenericInMemoryCatalogFactory.java | 2 +
.../table/catalog/GenericInMemoryCatalogStore.java | 2 +
.../GenericInMemoryCatalogStoreFactory.java | 2 +
.../GenericInMemoryCatalogStoreFactoryOptions.java | 2 +
.../flink/table/catalog/SchemaTranslator.java | 2 +
.../flink/table/delegation/PlannerFactory.java | 2 +
.../table/execution/StagingSinkJobStatusHook.java | 2 +
.../expressions/resolver/ExpressionResolver.java | 2 +
.../expressions/resolver/LocalOverWindow.java | 2 +
.../expressions/resolver/rules/ResolverRule.java | 1 +
.../flink/table/factories/TableFactoryUtil.java | 2 +
.../apache/flink/table/functions/SqlLikeUtils.java | 3 ++
.../table/operations/DescribeTableOperation.java | 2 +
.../table/operations/ExecutableOperation.java | 1 +
.../flink/table/operations/JoinQueryOperation.java | 1 +
.../apache/flink/table/operations/LikeType.java | 3 ++
.../flink/table/operations/NopOperation.java | 3 ++
.../OutputConversionModifyOperation.java | 1 +
.../flink/table/operations/SetQueryOperation.java | 1 +
.../table/operations/ShowCatalogsOperation.java | 2 +
.../table/operations/ShowColumnsOperation.java | 2 +
.../table/operations/ShowCreateTableOperation.java | 2 +
.../table/operations/ShowCreateViewOperation.java | 2 +
.../operations/ShowCurrentCatalogOperation.java | 2 +
.../operations/ShowCurrentDatabaseOperation.java | 2 +
.../table/operations/ShowDatabasesOperation.java | 2 +
.../table/operations/ShowFunctionsOperation.java | 3 ++
.../table/operations/ShowModulesOperation.java | 2 +
.../table/operations/ShowPartitionsOperation.java | 2 +
.../table/operations/ShowProceduresOperation.java | 2 +
.../table/operations/ShowTablesOperation.java | 2 +
.../flink/table/operations/ShowViewsOperation.java | 2 +
.../table/operations/SinkModifyOperation.java | 1 +
.../table/operations/TruncateTableOperation.java | 2 +
.../table/operations/UnloadModuleOperation.java | 2 +
.../table/operations/UseCatalogOperation.java | 2 +
.../table/operations/UseDatabaseOperation.java | 2 +
.../table/operations/UseModulesOperation.java | 2 +
.../operations/WindowAggregateQueryOperation.java | 1 +
.../table/operations/command/AddJarOperation.java | 2 +
.../table/operations/command/ClearOperation.java | 2 +
.../table/operations/command/HelpOperation.java | 2 +
.../table/operations/command/QuitOperation.java | 2 +
.../operations/command/RemoveJarOperation.java | 2 +
.../table/operations/command/ResetOperation.java | 2 +
.../table/operations/command/SetOperation.java | 2 +
.../operations/command/ShowJarsOperation.java | 2 +
.../operations/command/ShowJobsOperation.java | 2 +
.../table/operations/command/StopJobOperation.java | 2 +
.../operations/ddl/AddPartitionsOperation.java | 2 +
.../ddl/AlterCatalogFunctionOperation.java | 2 +
.../operations/ddl/AlterDatabaseOperation.java | 2 +
.../operations/ddl/AlterPartitionOperation.java | 2 +
.../ddl/AlterPartitionPropertiesOperation.java | 2 +
.../operations/ddl/AlterTableChangeOperation.java | 2 +
.../table/operations/ddl/AlterTableOperation.java | 2 +
.../operations/ddl/AlterTableRenameOperation.java | 2 +
.../operations/ddl/AlterTableSchemaOperation.java | 2 +
.../table/operations/ddl/AlterViewAsOperation.java | 2 +
.../table/operations/ddl/AlterViewOperation.java | 2 +
.../ddl/AlterViewPropertiesOperation.java | 2 +
.../operations/ddl/AlterViewRenameOperation.java | 2 +
.../operations/ddl/AnalyzeTableOperation.java | 2 +
.../table/operations/ddl/CompilePlanOperation.java | 2 +
.../ddl/CreateCatalogFunctionOperation.java | 2 +
.../operations/ddl/CreateCatalogOperation.java | 2 +
.../operations/ddl/CreateDatabaseOperation.java | 2 +
.../table/operations/ddl/CreateTableOperation.java | 2 +
.../ddl/CreateTempSystemFunctionOperation.java | 2 +
.../table/operations/ddl/CreateViewOperation.java | 2 +
.../ddl/DropCatalogFunctionOperation.java | 2 +
.../table/operations/ddl/DropCatalogOperation.java | 2 +
.../operations/ddl/DropDatabaseOperation.java | 2 +
.../flink/table/operations/ddl/DropOperation.java | 2 +
.../operations/ddl/DropPartitionsOperation.java | 2 +
.../table/operations/ddl/DropTableOperation.java | 2 +
.../ddl/DropTempSystemFunctionOperation.java | 2 +
.../table/operations/ddl/DropViewOperation.java | 2 +
.../operations/utils/ExecutableOperationUtils.java | 2 +
.../utils/OperationExpressionsUtils.java | 1 +
.../flink/table/typeutils/FieldInfoUtils.java | 3 ++
.../flink/table/catalog/AbstractCatalog.java | 2 +
.../flink/table/catalog/AbstractCatalogStore.java | 2 +
.../apache/flink/table/catalog/CatalogLock.java | 1 +
.../flink/table/catalog/CatalogStoreHolder.java | 1 +
.../stats/CatalogColumnStatisticsDataBinary.java | 3 ++
.../stats/CatalogColumnStatisticsDataBoolean.java | 3 ++
.../stats/CatalogColumnStatisticsDataDate.java | 3 ++
.../stats/CatalogColumnStatisticsDataDouble.java | 3 ++
.../stats/CatalogColumnStatisticsDataLong.java | 3 ++
.../stats/CatalogColumnStatisticsDataString.java | 3 ++
.../org/apache/flink/table/catalog/stats/Date.java | 3 ++
.../connector/source/DynamicFilteringEvent.java | 2 +
.../SupportsRowLevelModificationScan.java | 3 ++
.../connector/source/lookup/LookupOptions.java | 4 ++
.../cache/trigger/PeriodicCacheReloadTrigger.java | 3 ++
.../cache/trigger/TimedCacheReloadTrigger.java | 2 +
.../data/columnar/vector/BytesColumnVector.java | 1 +
.../flink/table/dataview/NullSerializer.java | 1 +
.../table/functions/BuiltInFunctionDefinition.java | 1 +
.../flink/table/functions/SpecializedFunction.java | 2 +
.../table/functions/TableAggregateFunction.java | 1 +
.../python/BuiltInPythonAggregateFunction.java | 3 ++
.../flink/table/functions/python/PythonEnv.java | 1 +
.../org/apache/flink/table/module/CoreModule.java | 2 +
.../apache/flink/table/plan/stats/ColumnStats.java | 1 +
.../table/types/extraction/ExtractionUtils.java | 1 +
.../table/types/inference/TypeInferenceUtil.java | 2 +
.../strategies/HiveAggDecimalPlusTypeStrategy.java | 2 +
.../strategies/SubsequenceInputTypeStrategy.java | 1 +
.../transforms/LegacyRawTypeTransformation.java | 2 +
.../types/utils/LogicalTypeDataTypeConverter.java | 2 +
.../apache/flink/table/utils/DateTimeUtils.java | 2 +
.../flink/table/watermark/WatermarkParams.java | 1 +
136 files changed, 327 insertions(+), 43 deletions(-)
