You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gi...@apache.org on 2026/07/01 22:06:06 UTC
(flink) branch dependabot/uv/flink-python/docs/idna-3.15 updated (da75b22852b -> 51941fc88aa)
This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch dependabot/uv/flink-python/docs/idna-3.15
in repository https://gitbox.apache.org/repos/asf/flink.git
discard da75b22852b Bump idna from 3.11 to 3.15 in /flink-python/docs
add 131d7c69018 [FLINK-39700][table-api-java] Consolidate query-change and drop validation into AlterMaterializedTableChangeOperation
add 4ac4c4a08e0 [FLINK-39700][table-planner] Name-based column matching; CREATE OR ALTER drops absent non-persisted columns
add abee47a3545 [FLINK-39650][table] Cache compiled patterns and drop hot-path log in regexpReplace
add 6eb7720a3d0 [FLINK-39650][table] Route REGEXP_REPLACE through BridgingSqlFunction
add 3c7a45a61b3 [FLINK-39650][table] Validate REGEXP_REPLACE literal patterns at plan time
add 4644cabd8bf [FLINK-39538][table] Support upsert output mode for FROM_CHANGELOG (#28164)
add 0515b156355 [hotfix][docs] Add missing CSV and JSON entries to DataStream formats overview (#28174)
add 34b6c8fbbc1 [FLINK-35856][table] Upgrade Calcite version to 1.37.0
add a9c40d34d95 [hotfix] Disable CAST with FORMAT as not supported yet
add 9ea76012821 [hotfix][docs] Fix incorrect HashMapStateBackend recommendations (#28094)
add 83472155500 [FLINK-39709][s3]Update documentation for native-s3 Implementation (#28200)
add cd34cf96b61 [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics (#28199)
add 8ffb4994f72 [hotfix][doc] Add flink-s3-fs-native in AGENTS.md
add 3ac4da3bb86 [hotfix] Fix compiliation for java 11 (#28225)
add 92ec61e6968 [FLINK-39731][table] Port from Calcite fix for `SqlValidatorImpl` should reject `MATCH_RECOGNIZE` with duplicate `MEASURE`
add 2741d9659d5 [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion
add 239e73ecebc [FLINK-39156][docs] Document ON CONFLICT
add 67fffa22fdf [FLINK-39733][build] Do not use `net.jcip.annotations`
add e62e227c1d3 [FLINK-39734][ci] Exclude 2.1 and 2.2 from GHA nightly
add e68a4887d3b [FLINK-39736][build] Do not allow Security Manager for jdk24+
add 4f8b4a88b1e [FLINK-39695][table] Outer join on nested field fails with conversion to relational algebra failed to preserve datatypes
add 91e58c24cee [FLINK-39742][tests] FlinkImageBuilder checks for Java 25
add f08eb434500 [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add
add 198ea6ae646 [hotfix][table/runtime] Remove redundant state access in LinkedMultiSetState.add
add 6f422510a8f [hotfix][table/runtime] Fix RowDataKeySerializerSnapshot.resolveSchemaCompatibility()
add 8d83511bbf0 [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs
add bf545feb4ee [FLINK-39746][build] Add jdk25 profile in `common_docker.sh`
add f3ffe4e1e1b [FLINK-39738] Use pekko ask() instead of tell() to ack the checkpoint
add 8177d666934 [FLINK-39619][docs] Add release notes for Flink 2.3
add 17216cee20f [hotfix][docs] Fix duplicate word typos in documentation
add 0b1da64c270 [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+
add 00f22d1b143 [FLINK-39750][tests] Drop `FailsOnJava11`
add 45295cf6260 [FLINK-38503] Adapt `DefaultClusterClientServiceLoader` to java 25
add 570cb32dc1e [FLINK-38192][table] Improve DynamicSourceUtils exception msg
add 4ef17078189 [FLINK-39762][ci] Add wget in case of java 25
add 3052f6469ba [hotfix] Allow security manager only if java version is less than 24
add 587a9d8b93e [FLINK-39590][table] Add support for CONNECTION in catalog APIs
add b07e12d2234 [FLINK-39737][s3] Switch to StandardRetryStrategy with configurable backoff for throttle-aware retry
add 04a31ba953f [FLINK-39145][tests] Skip counters accumulation when state isn't initialized
add 0b77c110793 [hotfix] Fix typo 'mim' -> 'min' (#28260)
add 8c029d0c27d [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify`
add 8eef95f62d9 [hotfix][tests] Migrate `ClusterUncaughtExceptionHandlerITCase` to JUnit5
add b194666f597 [FLINK-39751][tests] Add `FailsOnJava25`
add 383d5640d2a [FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator (#28229)
add 75120b525b8 [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor (#28251)
add 176939632f5 [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest`
add 34f770d7681 [FLINK-39702] Exclude netty 3.x from hadoop
add 7402fd1ed34 [FLINK-39726][table] Support `USING CONNECTION` clause in `CREATE TABLE`
add 4ea57c18cbe [FLINK-39794][tests] Bind StreamNetworkBenchmarkEnvironment to loopback
add 85a8e7ac0c3 [FLINK-39793][table] Bump quartz to 2.5.2
add 5d9860c29db [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - `AvroStreamingFileSinkITCase`
add 09547cea2e2 [hotfix][table] Fix flaky TemporalJoinITCase (#28273)
add 692507671e8 [FLINK-39425][metrics] `OpenTelemetryEventReporter` ignores `service.name` and `service.version config`
add bca2c0a6170 [FLINK-39636][table] Add produces_full_deletes parameter to TO_CHANGELOG
add 340fbf879fd [FLINK-39636][table] Refactor ToChangelogTypeStrategy
add d763453e045 [FLINK-39735][table] Expose input upsert key on TableSemantics
add 32f9e60eb9d [FLINK-39636][table] Emit partial DELETE rows in TO_CHANGELOG via upsert key
add e400c2c2213 [FLINK-39636][table] Remove unnecessary validation in TO_CHANGELOG
add c033b17fae2 [FLINK-39636][table] Widen output column nullability for partial deletes
add 59bb8b7a089 [FLINK-39379][table] Add state management to PTF test harness (#28212)
add fa2678926fa [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for CALCITE-7562 issue
add 3a785f917e8 [FLINK-39803][e2e] Ignore jdk25 native access and deprecated method warnings
add 810f0810478 [FLINK-39806][build] Add jdk25 required flags
add 6c756a084d4 [hotfix][docs] Fix code examples and minor issues in DataStream documentation
add f952a922ed3 [FLINK-39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE
add afd806e5594 [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document
add cc348d48096 [FLINK-39801][table] Skip serializing empty partition/order keys for PTF table args
add ea8905a85b6 [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25`
add 50ff839d0d6 [FLINK-39812][table] Migrate `FlinkTypeFactory` to java
add 8cce8e8f74f [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling
add a5a7925415b [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup (#28292)
add 04193173887 [hotfix][docs] Update Kafka connector doc version
add 3b31886d0c0 [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully ustilize s5cmd workers pool during downloads
add 8ca97a33d25 [FLINK-39811][s3] Document adjusted part size for s5cmd
add 8bf4827a3be [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop (#28286)
add cebcd7074a6 [FLINK-39821][table] Make REGEXP_REPLACE return type nullable (#28293)
add b63688eea97 [FLINK-39829][build] Bump scala to 2.12.21
add 4490b3074e6 [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG
add a3072eeb30b [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard (#28307)
add 690b6a3fff4 [hotfix][table-runtime] Fix typo in RowTimeMiniBatchAssignerOperator class name (#28172)
add 4e98dce2878 [hotfix][docs] Fix typo and heading level in state backends documentation (#28173)
add c3ec5690874 [FLINK-39845][tests] Fix SavepointITCase.testStopWithSavepointFailsOverToSavepoint under AdaptiveScheduler
add 15da2ba1471 [FLINK-39652][docs] Improve documentation for regexp functions (#28325)
add ed1738d57b4 [FLINK-39761][runtime] Set 'Connection: close' header in `StaticFileServerHandler` when sending '304 Not Modified' responses
add a62a144a5e9 [FLINK-39421][table] Fix metadata filter contract and add coverage
add 7a915ff7747 [FLINK-39857] Upgrade Pekko to 1.6.0
add 80189e470f4 [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions
add ef04bb14902 [FLINK-39823][table] Fix incorrect type inference for typed PTF table args
add 676365b5ee7 [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close (#28315)
add 8a5687898a6 [FLINK-39846][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler
add 5c0e9a8b45f [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload
add 832fb189bc2 [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh`
add a552ca37a50 [FLINK-39880][tests] Bump minikdc to 3.4.3
add af30def508f [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.5
add d720d58c3bf [hotfix] Fix some typos for connector-base, protobuf, runtime, table-planner and tests modules. (#28328)
add 6a8cb80a604 [FLINK-39820][docs] Update delta join documentation with new features in 2.3 (#28354)
add 5c2e1d0bb9e [FLINK-39882][table] Parser can not parse unparsed polymorphic table functions with several table args
add f77b8215687 [hotfix][tests] Replace deprecated `JavaConversions` in `TableTestBase`
add 392e0325e88 [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run
add c46e3aef836 [FLINK-39884][ci] Free up additional disk space for CI runs
add afb5ef94dd9 [FLINK-39879][tests] Stop CheckpointAcknowledgeFailureITCase hanging on slow CI
add 9a63a472e56 [hotfix][runtime/test] Enhance the test case CreditBasedPartitionRequestClientHandlerTest#testReceiveCompressedBuffer for checking totalQueueSizeInBytes (#28355)
add 4828c1869f8 [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch (#28365)
add f03c9044268 [FLINK-39868][table-runtime] Remove per-row logging from `parseUrl` and `subString`
add edfeb326914 [hotfix][build] Put commas into exclusion groups to avoid commas only
add f8274080d47 [FLINK-39711][runtime] Expose maxExceptions on exception message parameters
add f14ce1e6082 [FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector
add a46a571a701 [FLINK-39897][table] Fix SQL serialization when using limit without order
add 61723a08db5 [FLINK-37892][tests] Fix spurious TimeoutException in TestUtils#waitUntil for non-monotonic conditions (#28400)
add 9b324ee4416 [FLINK-39884][ci] Run free_disk_space.sh in the GitHub Actions e2e jobs
add efb41e61f12 [FLINK-39910][ci] Update burnett01/rsync-deployments to v8.0.5 for docs workflow
add 8d705d6f72c [FLINK-39912][runtime] Change the annotation from 'RepeatTest' to 'Test' in ForwardEdgesAdapterTest to reduce the time cost (#28393)
add ef4d88e2e50 [FLINK-39902][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished (#28378)
add aa52739877b [FLINK-39903][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByResourceRequirementsUpdated (#28379)
add 4f6db6ea8a5 [FLINK-39917][tests] Wait for RM disconnect log in JobMasterTriggerSavepointITCase (#28406)
add 0156b330949 [FLINK-39918][tests] Stop operator-restore tests hanging on unexpected job state (#28408)
add d6b7fad86b5 [FLINK-39915][table] Reject mixing positional and named function arguments
add 9ea2216ef0f [hotfix][tests] Reenable `PeriodicMaterializationManagerTest.testInitialDelay`
add 9540d89d121 [FLINK-39919][connector-base/tests] Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable (#28419)
add 4acf53ae18e [FLINK-34921][tests] Stop SystemProcessingTimeServiceTest hanging on timing jitter (#28405)
add 6d47db1d541 [FLINK-39914][runtime] Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation (#28398)
add 6d106cda908 [FLINK-39922][runtime/test] Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain (#28425)
add d6a7f714061 [FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci
add 757749336ea [FLINK-39778][s3] Recoverable writer silently loses the in-flight tail on resume (#28268)
add 5338ead2a0f [FLINK-39879][tests] Avoid deploy RPC timeout in CheckpointAcknowledgeFailureITCase (#28377)
add d70e596602b [FLINK-39847][table] Support in-place conversion of a table to a materialized table (#28287)
add 2d515d3bd47 [FLINK-39763][table] Allow inferring constants with `IS NOT DISTINCT FROM`
add 4da1660776d [FLINK-39679][table-planner] Fix implicit casts for PTF calls
add f353726e9db [FLINK-36602][table] Enable CALCITE-6044 optimization
add 8de3293e2d9 [FLINK-36602][table] Upgrade Calcite version to 1.38.0
add cfbbb0a6a5c [FLINK-36602][tests] Replace deprecated `JavaConversions` in `FlinkRelMdHandlerTest` and its children
add 17fda6c63ca [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file (#28442)
add 019c6249ddf [FLINK-39948][planner] Fix compile issue in jdk11 for table-planner
add 06a929fbd6f [FLINK-37663][connector-base] Add test reproducing FutureCompletingBlockingQueue lost wakeup
add 22c99868375 [FLINK-37663][connector-base] Remove stale put conditions to fix lost wakeup
add e009616411c [FLINK-38534][runtime/tests] Fix LocalRecoveryTest racing the async task deployment
add d996802ab86 [FLINK-29984][flink-metrics] Export Prometheus histogram min and max (#28465)
add c23dea2f497 [FLINK-39913][table-planner] Improve the error message for unsupported changelog modes
add 4902753429f [FLINK-35562][table-planner] Bound result wait in RestoreTestBase to avoid CI hangs (#28404)
add 41143782de7 [hotfix][table] Fix view comment derived from QueryOperation summary string (#28482)
add 77f849095b7 [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession`
add d6b9ff65e29 [FLINK-39730][runtime] Honor `maxExceptions` on `ApplicationExceptionsHandler`
add 2afa8f1bbba [hotfix] Replace deprecated procedure syntax for scala
add a8d6a287ae2 [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
add 6627acb4231 [FLINK-39767][tests][JUnit5 migration] Module: flink-statebackend-forst
add fd5060787f8 [FLINK-39670][build] Update test-scope dependencies (kafka-clients, okhttp, wiremock)
add b26face7c93 [FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration
add cce8840bbfc [FLINK-39125][table] Support injective casts from BINARY/VARBINARY to CHAR/VARCHAR for upsert keys
add 8fbca66d516 [FLINK-39782][table] Add SNAPSHOT built-in function definition and type inference (#28396)
add 9bc156b7faf [FLINK-39909][state] Fix heap state backend savepoint NPE with null map state values
add d2ddbe0f18b [FLINK-39817][table] Upgrade Calcite to 1.39.0
add 0e852ba33e1 [FLINK-39817][table] Do not use deprecated `SqlPrettyWriter` constructor
add 160aba5fd4a [FLINK-39817][table] Replace deprecated `LogicalProject.create`
add 316d926c34e [FLINK-39817][table] Replace deprecated `JavaConversions` in `TemporalJoinUtil`
add e7084a6d634 [FLINK-39966][table-planner] FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only
add dadd8d63e41 [FLINK-39866][table] Remove dead KEYVALUE code from SqlFunctionUtils and StringCallGen
add 92e6fe8c9b1 [FLINK-39828][table] Upgrade Calcite to 1.40.0
add 23cec76515a [FLINK-39637][state] Add filter pushdown support for savepoint connector
add 67eba458114 [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. (#28434)
add ca0cf0b6cfe [FLINK-39769][tests][JUnit5 migration] Module: flink-examples-streaming
add 995609633b1 [FLINK-37404][FLINK-36334][API / Core] Reenable Migration Tests for Filnk 2.x
add b22372badbb [FLINK-39978][runtime-web] Restyle Cancel Job/Application action as a danger button
add 3212758626d [FLINK-39982][table] Drop `SqlCollectionTypeNameSpec` and `SqlJsonQueryFunction` from Flink codebase
add 9130898778d [FLINK-39983][table-planner] Remove `FlinkPruneEmptyRules` in favor of Calcite's version
add b383d4b9025 [FLINK-38918][python][kafka connector] support per cluster offset for DynamicKafkaSource in pyflink (#28512)
add 049a6b225cf [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit`
add d5c27cd9eb3 [FLINK-39451][release] Mark 2.3 as stable in docs (#28528)
add 0851e272cb2 [FLINK-39451][release] Finalize release notes for Flink 2.3
add adc9c1d1f61 [FLINK-39499][tests] Replace MinIO with SeaweedFS
add 59b5196e105 [FLINK-39061][example] Roll back StateMachineExample to v1 State API
add 59c4ca7d1b7 [FLINK-39993][docs] Correct documentation examples for ProcessTableFunctionTestHarness (#28543)
add c5d3273ffdd [hotfix][release] Update japicmp configuration for 2.3.0 (#28536)
add ca95b59981b [FLINK-39911][historyserver] Introduce ArchiveStorage abstraction and FileArchiveStorage implementation
add c1f4c5ea64c [FLINK-39911][historyserver] Extract AbstractHistoryServerHandler from HistoryServerStaticFileServerHandler
add d531fb808ea [FLINK-39911][historyserver] Support RocksDB as archive storage backend
add 0fbd749cacc [FLINK-39911][docs] Document HistoryServer archive storage backend
add 956659fdfe8 [hotfix] [docs] Fix java.util.Collection reference in DataStream overview
add b7d0869ea26 [FLINK-39994][table] Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness (#28545)
add cb17c87788a [FLINK-39378][table] Add support for Context, timers and on_time to ProcessTableFunctionTestHarness (#28326)
add 5b60aba2ecb [FLINK-40000][runtime/test] Remove the redundant testing util class SynchronousComponentMainThreadExecutor (#28481)
add 64775b024b0 [FLINK-39999][table] Make Flink Sql calls unparsable as it is required by Calcite 1.42.0
add 1c17615d998 [FLINK-39999][table] Add temporary DeepCopyUnparsingTesterImpl before Calcite 1.42.0 upgrade
add 1722d6ac23f [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests
add aebc8a42bd0 Refactor RexNodeExtractor to use Scala collections
add ab55f18cd37 Revert "Refactor RexNodeExtractor to use Scala collections"
add f75b59424cd [hotfix][build] Bump netty to 4.2.15.Final
add 5d5184e0427 [FLINK-39998][state] Surface root cause exception when parallel RocksDB state download fails
add 63f4bf958e6 [hotfix][docs] Document how to run the S3 end-to-end tests
add 31fb173d9cb [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest (#28350)
add 063b46ef668 [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase
add e91a0ce09e5 [FLINK-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN
add 291f68a5e0b [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness (#28574)
add 80188ebf064 [FLINK-40021][table] `AND` for pushdown filters should be in uppercase
add 6afaa60978c [FLINK-40008][security] Replace fixed delegation token renewal retry backoff with exponential backoff
add 2045cb68ca3 [FLINK-39987][state] update State Processor API doc to include filter pushdown examples
add 9e663f3e3ad [hotfix][docs] Fix broken link in PyFlink documentation
add 1268adfdb03 [FLINK-40009][tests] Enforce timeout in RescaleTimelineITCase wait helper
add ad2dee480a6 [FLINK-40010][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange
add ce4cec57bc6 [FLINK-40012][table] Correctly inject Context into scalar-only PTFs in ProcessTableFunctionTestHarness (#28579)
add 9ca06dd9da6 [FLINK-40029][tests] Use Hadoop 3.4.3 in nightly
add e9001f6a85c [FLINK-38233][table] Adds support to StreamNonDeterministicUpdatePlanVisitor for PTFs
add 823d9d509f2 [FLINK-39776][runtime][core] Expose JobInfo on SourceOperators
add 7b19c349f0d [FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan
add 990bc73dd25 [FLINK-39956][metrics] Add heap memory pool metrics (Used/Max/CollectionUsed/CollectionMax) (#28582)
add cbd7792ee9b [FLINK-38536][tests] Deploy synchronously to avoid deployment-callback race
add 4da07302e40 [FLINK-40028][runtime-web] Update Angular to v21 and ng-zorro-antd to v21 (#28593)
add 51941fc88aa Bump idna from 3.11 to 3.15 in /flink-python/docs
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (da75b22852b)
\
N -- N -- N refs/heads/dependabot/uv/flink-python/docs/idna-3.15 (51941fc88aa)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/actions/job_init/action.yml | 10 +
.github/workflows/docs-legacy.yml | 4 +-
.github/workflows/docs.yml | 10 +-
.github/workflows/nightly-trigger.yml | 43 +-
.github/workflows/nightly.yml | 4 +-
.github/workflows/template.flink-ci.yml | 17 +-
.github/workflows/template.pre-compile-checks.yml | 2 +-
AGENTS.md | 2 +-
azure-pipelines.yml | 2 +-
docs/content.zh/_index.md | 3 +-
.../docs/connectors/datastream/formats/overview.md | 2 +
.../docs/deployment/advanced/historyserver.md | 13 +
docs/content.zh/docs/deployment/filesystems/gcs.md | 2 +-
docs/content.zh/docs/deployment/filesystems/s3.md | 2 +
.../content.zh/docs/deployment/metric_reporters.md | 2 +-
.../docs/dev/datastream/application_parameters.md | 5 +-
.../content.zh/docs/dev/datastream/java_lambdas.md | 4 +-
.../docs/dev/datastream/operators/asyncio.md | 2 +-
.../docs/dev/datastream/operators/overview.md | 8 +-
docs/content.zh/docs/dev/datastream/overview.md | 4 +-
docs/content.zh/docs/dev/datastream/testing.md | 4 +-
docs/content.zh/docs/dev/table/functions/ptfs.md | 373 +-
docs/content.zh/docs/dev/table/tuning.md | 17 +-
.../docs/learn-flink/streaming_analytics.md | 4 +-
docs/content.zh/docs/libs/state_processor_api.md | 280 +-
docs/content.zh/docs/ops/state/state_backends.md | 48 +-
.../docs/sql/materialized-table/statements.md | 123 +
docs/content.zh/docs/sql/reference/ddl/alter.md | 68 +
docs/content.zh/docs/sql/reference/ddl/create.md | 2 +-
docs/content.zh/docs/sql/reference/dml/insert.md | 172 +
.../content.zh/docs/sql/reference/queries/joins.md | 2 +
docs/content.zh/release-notes/flink-2.3.md | 317 +
docs/content/_index.md | 1 +
.../docs/connectors/datastream/formats/overview.md | 2 +
.../docs/deployment/advanced/historyserver.md | 13 +
docs/content/docs/deployment/filesystems/gcs.md | 2 +-
docs/content/docs/deployment/filesystems/s3.md | 2 +
docs/content/docs/deployment/metric_reporters.md | 2 +-
.../docs/dev/datastream/application_parameters.md | 9 +-
docs/content/docs/dev/datastream/execution_mode.md | 6 +-
docs/content/docs/dev/datastream/java_lambdas.md | 8 +-
.../docs/dev/datastream/operators/asyncio.md | 6 +-
.../docs/dev/datastream/operators/overview.md | 8 +-
docs/content/docs/dev/datastream/overview.md | 4 +-
docs/content/docs/dev/datastream/testing.md | 14 +-
docs/content/docs/dev/table/functions/ptfs.md | 373 +-
docs/content/docs/dev/table/tuning.md | 15 +-
docs/content/docs/libs/state_processor_api.md | 140 +-
docs/content/docs/ops/batch/batch_shuffle.md | 4 +-
docs/content/docs/ops/state/state_backends.md | 14 +-
.../docs/sql/materialized-table/statements.md | 123 +
docs/content/docs/sql/reference/ddl/alter.md | 68 +
docs/content/docs/sql/reference/ddl/create.md | 2 +-
docs/content/docs/sql/reference/dml/insert.md | 172 +
.../docs/sql/reference/queries/changelog.md | 162 +-
docs/content/docs/sql/reference/queries/joins.md | 2 +
docs/content/release-notes/flink-2.3.md | 290 +-
docs/data/sql_functions.yml | 47 +-
docs/data/sql_functions_zh.yml | 46 +-
.../generated/history_server_configuration.html | 6 +
.../shortcodes/generated/rest_v1_dispatcher.html | 10 +
.../generated/security_configuration.html | 12 +-
.../security_delegation_token_section.html | 12 +-
.../generated/table_config_configuration.html | 6 +
docs/setup_docs.sh | 2 +-
docs/static/generated/rest_v1_dispatcher.yml | 9 +
.../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 27 +-
.../flink/architecture/rules/ConnectorRules.java | 3 -
.../apache/flink/client/cli/CliFrontendParser.java | 11 +-
.../DefaultClusterClientServiceLoader.java | 21 +-
.../base/source/hybrid/HybridSourceReader.java | 2 +-
.../source/hybrid/HybridSourceSplitEnumerator.java | 6 +
.../FutureCompletingBlockingQueue.java | 18 +-
.../reader/fetcher/SplitFetcherManagerTest.java | 2 +-
.../FutureCompletingBlockingQueueTest.java | 54 +
flink-core/pom.xml | 4 +-
.../connector/source/RichSourceReaderContext.java | 6 +
.../api/connector/source/SourceReaderContext.java | 12 +
.../connector/source/SplitEnumeratorContext.java | 11 +
.../flink/configuration/HistoryServerOptions.java | 19 +
.../flink/configuration/SecurityOptions.java | 26 +-
.../base/VariantSerializerUpgradeTest.java | 8 +-
.../source/mocks/MockSplitEnumeratorContext.java | 10 +
.../core/security/FlinkSecurityManagerTest.java | 2 +
.../src/main/resources/META-INF/NOTICE | 6 +-
flink-dist/pom.xml | 7 +
flink-dist/src/main/flink-bin/bin/config.sh | 2 +-
flink-dist/src/main/resources/config.yaml | 2 +-
flink-end-to-end-tests/README.md | 39 +-
.../flink-end-to-end-tests-common/pom.xml | 7 +
.../flink-end-to-end-tests-sql/pom.xml | 8 +
.../flink-sql-client-test/pom.xml | 4 +-
.../src/test/java/SqlClientITCase.java | 10 +-
flink-end-to-end-tests/pom.xml | 12 +-
flink-end-to-end-tests/run-nightly-tests.sh | 3 +
flink-end-to-end-tests/test-scripts/common.sh | 10 +-
.../test-scripts/common_docker.sh | 6 +
flink-end-to-end-tests/test-scripts/common_s3.sh | 2 +-
.../{common_s3_minio.sh => common_s3_seaweedfs.sh} | 59 +-
.../test-scripts/test_batch_wordcount.sh | 17 +-
.../test-scripts/test_confluent_schema_registry.sh | 4 +-
.../test-scripts/test_file_sink.sh | 7 +-
.../test_kubernetes_materialized_table.sh | 2 +-
.../test-scripts/test_pyflink.sh | 4 +-
.../examples/statemachine/StateMachineExample.java | 50 +-
.../streaming/test/StreamingExamplesITCase.java | 34 +-
.../windowing/TopSpeedWindowingExampleITCase.java | 28 +-
.../test/socket/SocketWindowWordCountITCase.java | 26 +-
.../org.junit.jupiter.api.extension.Extension | 0
.../cce59259-d3cb-4048-a1bd-31197f847189 | 12 +
flink-filesystems/flink-gs-fs-hadoop/pom.xml | 18 +-
.../src/main/resources/META-INF/NOTICE | 129 +-
.../resources/META-INF/licenses/LICENSE.stax2-api} | 0
.../flink/fs/gs/GSFileSystemBehaviorITCase.java | 69 +
.../flink/fs/gs/GSRecoverableWriterITCase.java | 132 +
.../org/apache/flink/fs/gs/GSTestCredentials.java | 53 +
flink-filesystems/flink-hadoop-fs/pom.xml | 8 +
flink-filesystems/flink-s3-fs-base/pom.xml | 4 +-
.../fs/s3/common/AbstractS3FileSystemFactory.java | 13 +
.../flink/fs/s3/common/FlinkS3FileSystem.java | 39 +-
.../flink/fs/s3/common/FlinkS3FileSystemTest.java | 73 +
... HAApplicationRunOnSeaweedFsS3StoreITCase.java} | 30 +-
....java => HAJobRunOnSeaweedFsS3StoreITCase.java} | 29 +-
...inioITCase.java => S5CmdOnSeaweedFsITCase.java} | 29 +-
...tContainer.java => SeaweedFsTestContainer.java} | 33 +-
...erTest.java => SeaweedFsTestContainerTest.java} | 16 +-
...HAApplicationRunOnHadoopS3FileSystemITCase.java | 6 +-
.../HAJobRunOnHadoopS3FileSystemITCase.java | 6 +-
.../s3hadoop/S5CmdOnHadoopS3FileSystemITCase.java | 7 +-
flink-filesystems/flink-s3-fs-native/README.md | 86 +-
flink-filesystems/flink-s3-fs-native/pom.xml | 2 +-
.../fs/s3native/NativeS3FileSystemFactory.java | 30 +-
.../apache/flink/fs/s3native/S3ClientProvider.java | 98 +-
.../NativeS3RecoverableFsDataOutputStream.java | 23 +-
.../s3native/writer/NativeS3RecoverableWriter.java | 107 +-
.../src/main/resources/META-INF/NOTICE | 28 +-
.../fs/s3native/NativeS3FileSystemFactoryTest.java | 51 +
.../flink/fs/s3native/S3ClientProviderTest.java | 68 +
.../writer/InMemoryNativeS3Operations.java | 165 +
.../NativeS3RecoverableWriterRecoveryTest.java | 349 +
...HAApplicationRunOnPrestoS3FileSystemITCase.java | 6 +-
.../HAJobRunOnPrestoS3FileSystemITCase.java | 6 +-
.../s3presto/S5CmdOnPrestoS3FileSystemITCase.java | 7 +-
.../formats/avro/AvroStreamingFileSinkITCase.java | 26 +-
flink-formats/flink-compress/pom.xml | 4 +
flink-formats/flink-hadoop-bulk/pom.xml | 12 +
flink-formats/flink-orc/pom.xml | 4 +
flink-formats/flink-parquet/pom.xml | 8 +
flink-formats/flink-protobuf/pom.xml | 2 +-
.../protobuf/util/PbSchemaValidationUtils.java | 4 +-
flink-formats/flink-sequence-file/pom.xml | 4 +
flink-fs-tests/pom.xml | 8 +
.../hdfstests/ContinuousFileProcessingITCase.java | 48 +-
.../ContinuousFileProcessingMigrationTest.java | 76 +-
.../hdfstests/ContinuousFileProcessingTest.java | 185 +-
.../flink/hdfstests/DistributedCacheDfsTest.java | 51 +-
.../java/org/apache/flink/hdfstests/HDFSTest.java | 99 +-
.../org.junit.jupiter.api.extension.Extension | 0
.../flink/cep/operator/CEPMigrationTest.java | 8 +-
.../apache/flink/state/api/SavepointReader.java | 32 +-
.../apache/flink/state/api/filter/BoundInfo.java | 33 +-
.../flink/state/api/filter/EmptyKeyFilter.java | 48 +-
.../flink/state/api/filter/ExactKeyFilter.java | 63 +
.../flink/state/api/filter/RangeKeyFilter.java | 124 +
.../flink/state/api/filter/SavepointKeyFilter.java | 121 +
.../api/input/FilteringCloseableIterator.java | 71 +
.../state/api/input/KeyedStateInputFormat.java | 77 +-
.../table/SavepointDataStreamScanProvider.java | 24 +-
.../state/table/SavepointDynamicTableSource.java | 40 +-
.../state/table/SavepointFilterTranslator.java | 371 +
.../state/api/SavepointReaderKeyedStateITCase.java | 214 +-
.../api/input/FilteringCloseableIteratorTest.java | 121 +
.../state/api/input/KeyedStateInputFormatTest.java | 81 +
.../table/SavepointDynamicTableSourceTest.java | 273 +-
.../state/table/SavepointFilterTranslatorTest.java | 805 +
flink-metrics/flink-metrics-influxdb/pom.xml | 2 +-
.../events/otel/OpenTelemetryEventReporter.java | 1 +
.../otel/OpenTelemetryEventReporterTest.java | 23 +
.../prometheus/AbstractPrometheusReporter.java | 26 +-
.../PrometheusReporterTaskScopeTest.java | 24 +
.../metrics/prometheus/PrometheusReporterTest.java | 2 +
flink-python/README.md | 6 +-
.../docs/user_guide/table_api_tutorial.rst | 2 +-
flink-python/pom.xml | 8 +-
.../pyflink/datastream/connectors/dynamic_kafka.py | 36 +-
.../connectors/tests/test_dynamic_kafka.py | 93 +-
.../table/mixing_use_of_datastream_and_table.py | 2 +-
flink-python/pyflink/examples/table/multi_sink.py | 2 +-
.../pyflink/examples/table/pandas/pandas_udaf.py | 2 +-
.../pyflink/examples/table/process_json_data.py | 2 +-
.../examples/table/process_json_data_with_udf.py | 2 +-
.../pyflink/examples/table/streaming_word_count.py | 2 +-
.../examples/table/windowing/over_window.py | 2 +-
.../examples/table/windowing/session_window.py | 2 +-
.../examples/table/windowing/sliding_window.py | 2 +-
.../examples/table/windowing/tumble_window.py | 2 +-
flink-python/pyflink/examples/table/word_count.py | 2 +-
flink-python/pyflink/pyflink_gateway_server.py | 3 +
flink-python/pyflink/table/table.py | 25 +-
flink-python/pyflink/table/table_environment.py | 4 +-
.../table/tests/test_catalog_completeness.py | 11 +-
.../pyflink/table/tests/test_compiled_plan.py | 48 +-
.../pyflink/table/tests/test_expression.py | 4 +-
flink-python/src/main/resources/META-INF/NOTICE | 4 +-
flink-rpc/flink-rpc-akka/pom.xml | 4 +-
.../src/main/resources/META-INF/NOTICE | 30 +-
flink-runtime-web/README.md | 2 +-
flink-runtime-web/pom.xml | 15 +-
...dler.java => AbstractHistoryServerHandler.java} | 227 +-
.../runtime/webmonitor/history/ArchiveStorage.java | 104 +
.../webmonitor/history/FileArchiveStorage.java | 125 +
.../runtime/webmonitor/history/HistoryServer.java | 94 +-
.../HistoryServerApplicationArchiveFetcher.java | 100 +-
.../history/HistoryServerArchiveFetcher.java | 109 +-
.../history/HistoryServerRocksDBHandler.java | 55 +
.../HistoryServerStaticFileServerHandler.java | 228 +-
.../webmonitor/history/RocksDBArchiveStorage.java | 299 +
.../src/main/resources/META-INF/NOTICE | 951 +-
.../history/AbstractHistoryServerHandlerTest.java | 187 +
.../webmonitor/history/ArchiveStorageTest.java | 199 +
.../HistoryServerStaticFileServerHandlerTest.java | 95 -
.../src/test/resources/rest_api_v1.snapshot | 5 +-
flink-runtime-web/web-dashboard/.eslintrc.js | 23 +-
flink-runtime-web/web-dashboard/.stylelintrc.js | 17 +
flink-runtime-web/web-dashboard/package-lock.json | 30638 +++++--------------
flink-runtime-web/web-dashboard/package.json | 88 +-
.../web-dashboard/src/app/app.interceptor.ts | 2 +-
.../status/application-status.component.html | 7 +-
.../status/application-status.component.less | 13 +-
.../status/application-status.component.ts | 2 +
.../job-detail/status/job-status.component.html | 7 +-
.../job-detail/status/job-status.component.less | 13 +-
.../job/job-detail/status/job-status.component.ts | 2 +
.../pages/job/overview/job-overview.component.ts | 2 +-
flink-runtime-web/web-dashboard/src/main.ts | 3 +-
flink-runtime-web/web-dashboard/tsconfig.json | 17 +-
flink-runtime/pom.xml | 10 +-
.../checkpoint/CheckpointCoordinatorGateway.java | 5 +-
.../filemerging/FileMergingMetricGroup.java | 2 +-
.../InternalExecutionGraphAccessor.java | 2 +
.../partition/consumer/RemoteInputChannel.java | 7 +-
.../tier/disk/SubpartitionDiskCacheManager.java | 2 +-
.../remote/SubpartitionRemoteCacheManager.java | 3 +-
.../runtime/jobgraph/SavepointRestoreSettings.java | 109 +-
.../jobmanager/DefaultApplicationStore.java | 2 +-
.../jobmanager/DefaultExecutionPlanStore.java | 2 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 3 +-
.../flink/runtime/metrics/util/MetricUtils.java | 28 +
.../coordination/OperatorCoordinator.java | 4 +
.../coordination/OperatorCoordinatorHolder.java | 23 +-
.../RecreateOnResetOperatorCoordinator.java | 6 +
.../org/apache/flink/runtime/rest/RestClient.java | 110 +-
.../application/ApplicationExceptionsHandler.java | 22 +-
.../legacy/files/StaticFileServerHandler.java | 4 +
.../ApplicationExceptionsInfoWithHistory.java | 11 +-
.../runtime/rest/messages/ConfigurationInfo.java | 2 +
.../application/ApplicationExceptionsHeaders.java | 7 +-
.../job/JobExceptionsMessageParameters.java | 2 +-
.../messages/job/metrics/AggregatedMetric.java | 2 +-
.../messages/job/rescales/JobRescalesHistory.java | 2 +
.../token/DefaultDelegationTokenManager.java | 56 +-
.../coordinator/SourceCoordinatorContext.java | 6 +
.../state/heap/HeapKeyValueStateIterator.java | 4 +-
.../runtime/state/metrics/StateMetricBase.java | 9 +
.../taskexecutor/rpc/RpcCheckpointResponder.java | 14 +-
.../runtime/tasks/AsyncCheckpointRunnable.java | 43 +-
.../source/RichSourceReaderContextTest.java | 89 +
.../AbstractAsyncRunnableStreamOperatorTest.java | 3 +
.../TaskDeploymentDescriptorFactoryTest.java | 20 +-
.../runtime/entrypoint/ClusterEntrypointTest.java | 3 +
.../ClusterUncaughtExceptionHandlerITCase.java | 27 +-
.../executiongraph/ExecutionGraphFinishTest.java | 14 +-
.../executiongraph/ExecutionVertexCancelTest.java | 9 +-
.../executiongraph/FinalizeOnMasterTest.java | 26 +-
...editBasedPartitionRequestClientHandlerTest.java | 23 +-
.../jobgraph/SavepointRestoreSettingsTest.java | 134 +
.../jobmaster/utils/TestingJobMasterGateway.java | 3 +-
.../runtime/metrics/util/MetricUtilsTest.java | 31 +
.../MockOperatorCoordinatorContext.java | 8 +
.../OperatorCoordinatorHolderTest.java | 2 +
.../AbstractFineGrainedSlotManagerITCase.java | 3 +
.../apache/flink/runtime/rest/RestClientTest.java | 179 +
.../ApplicationExceptionsHandlerTest.java | 141 +-
.../legacy/files/StaticFileServerHandlerTest.java | 64 +
.../job/JobExceptionsMessageParametersTest.java | 54 +
.../runtime/scheduler/SchedulerTestingUtils.java | 32 +
.../runtime/scheduler/adaptive/ExecutingTest.java | 5 +
.../adaptive/ForwardEdgesAdapterTest.java | 4 +-
.../scheduler/adaptive/LocalRecoveryTest.java | 16 +-
.../adaptive/timeline/RescaleTimelineITCase.java | 86 +-
.../adaptivebatch/AdaptiveBatchSchedulerTest.java | 55 +-
.../ExecutionTimeBasedSlowTaskDetectorTest.java | 14 +-
.../token/DefaultDelegationTokenManagerTest.java | 69 +
.../coordinator/SourceCoordinatorContextTest.java | 11 +
.../MetricsTrackingAggregatingStateTest.java | 8 +-
.../metrics/MetricsTrackingListStateTest.java | 8 +-
.../state/metrics/MetricsTrackingMapStateTest.java | 16 +-
.../metrics/MetricsTrackingReducingStateTest.java | 8 +-
.../metrics/MetricsTrackingStateTestBase.java | 15 +-
.../metrics/MetricsTrackingValueStateTest.java | 52 +-
.../runtime/util/FlinkSecurityManagerITCase.java | 2 +
.../StreamNetworkBenchmarkEnvironment.java | 11 +-
.../runtime/tasks/AsyncCheckpointRunnableTest.java | 79 +
.../tasks/SystemProcessingTimeServiceTest.java | 28 +-
.../common/PeriodicMaterializationManagerTest.java | 3 +
.../ForStIncrementalCheckpointRescalingTest.java | 191 +-
.../apache/flink/state/forst/ForStInitITCase.java | 22 +-
.../forst/ForStMemoryControllerUtilsTest.java | 77 +-
.../state/forst/ForStMultiClassLoaderTest.java | 21 +-
.../state/forst/ForStNativeMetricOptionsTest.java | 25 +-
.../state/forst/ForStOperationsUtilsTest.java | 31 +-
.../state/forst/ForStResourceContainerTest.java | 124 +-
.../state/forst/ForStStateBackendConfigTest.java | 337 +-
.../state/forst/ForStStateBackendFactoryTest.java | 56 +-
.../flink-statebackend-rocksdb/pom.xml | 2 +-
.../state/rocksdb/RocksDBStateDownloader.java | 55 +-
.../flink/state/rocksdb/sstmerge/Compactor.java | 9 +-
.../state/rocksdb/RocksDBStateDownloaderTest.java | 168 +
flink-streaming-java/pom.xml | 4 +-
.../runtime/tasks/StreamTaskSystemExitTest.java | 2 +
.../flink-sql-client/src/test/resources/sql/set.q | 132 +-
.../MaterializedTableManager.java | 183 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../table/gateway/rest/SessionRelatedITCase.java | 2 +-
.../service/MaterializedTableConversionITCase.java | 343 +
.../service/MaterializedTableStatementITCase.java | 10 +-
.../service/MaterializedTableTestUtils.java | 53 +
.../flink-sql-gateway/src/test/resources/sql/set.q | 48 +-
flink-table/flink-sql-parser/pom.xml | 9 +-
.../src/main/codegen/data/Parser.tdd | 4 +
.../src/main/codegen/includes/parserImpls.ftl | 86 +-
.../src/main/codegen/templates/Parser.jj | 356 +-
.../main/java/org/apache/calcite/sql/SqlJoin.java | 289 -
.../calcite/sql/fun/SqlJsonQueryFunction.java | 192 -
.../org/apache/calcite/sql/type/SqlTypeFamily.java | 280 -
.../org/apache/calcite/sql/type/SqlTypeName.java | 1055 -
.../flink/sql/parser/SqlPartitionSpecProperty.java | 13 +-
.../org/apache/flink/sql/parser/SqlProperty.java | 10 +-
.../apache/flink/sql/parser/SqlUnparseUtils.java | 12 +
.../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 | 47 +-
.../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 | 33 +-
.../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 | 70 +-
.../SqlCreateOrAlterMaterializedTable.java | 50 +-
.../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 | 44 +-
.../sql/parser/ddl/table/SqlCreateTableAs.java | 34 +-
.../sql/parser/ddl/table/SqlCreateTableLike.java | 36 +-
.../flink/sql/parser/ddl/table/SqlDropTable.java | 25 +-
.../flink/sql/parser/ddl/table/SqlTableLike.java | 34 +-
.../flink/sql/parser/ddl/view/SqlAlterViewAs.java | 35 +-
.../parser/ddl/view/SqlAlterViewProperties.java | 20 +
.../sql/parser/ddl/view/SqlAlterViewRename.java | 21 +
.../flink/sql/parser/ddl/view/SqlCreateView.java | 33 +-
.../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 +-
.../flink/sql/parser/utils/ParserResource.java | 4 +
.../sql/parser/validate/FlinkSqlConformance.java | 25 +-
.../sql/parser/DeepCopyUnparsingTesterImpl.java | 155 +
.../sql/parser/ExtendedSqlRowTypeNameSpecTest.java | 17 +-
.../flink/sql/parser/FlinkDDLDataTypeTest.java | 10 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 136 +
.../flink/sql/parser/FlinkSqlUnParserTest.java | 2 +-
.../MaterializedTableStatementUnParserTest.java | 3 +-
.../apache/flink/table/api/PartitionedTable.java | 22 +-
.../java/org/apache/flink/table/api/Table.java | 15 +-
.../flink/table/api/config/TableConfigOptions.java | 15 +
.../table/api/internal/TableEnvironmentImpl.java | 7 +
.../apache/flink/table/catalog/CatalogManager.java | 421 +-
.../table/catalog/GenericInMemoryCatalog.java | 93 +
.../table/catalog/QueryOperationCatalogView.java | 4 +-
.../catalog/listener/AlterConnectionEvent.java | 72 +
.../listener/ConnectionModificationEvent.java | 29 +-
.../catalog/listener/CreateConnectionEvent.java | 71 +
.../catalog/listener/DropConnectionEvent.java | 72 +
.../resolver/rules/ResolveCallByArgumentsRule.java | 5 +
.../flink/table/operations/SortQueryOperation.java | 25 +-
.../AlterMaterializedTableChangeOperation.java | 147 +-
.../ConvertTableToMaterializedTableOperation.java | 107 +
.../FullAlterMaterializedTableOperation.java | 14 +-
.../MaterializedTableChangeHandler.java | 150 +-
.../flink/table/api/TableEnvironmentTest.java | 1 +
.../flink/table/catalog/CatalogManagerTest.java | 222 +
.../table/catalog/GenericInMemoryCatalogTest.java | 56 +
...ializedTableAsQueryOperationValidationTest.java | 199 +
...rializedTableChangeOperationValidationTest.java | 189 +
.../MaterializedTableChangeHandlerTest.java | 195 +
.../runtime/types/KryoTraversableSerializer.scala | 2 +-
.../table/api/typeutils/CaseClassComparator.scala | 8 +-
.../flink/table/api/typeutils/UnitSerializer.scala | 6 +-
.../api/typeutils/OptionSerializerUpgradeTest.java | 2 -
.../ScalaEitherSerializerUpgradeTest.java | 2 -
.../typeutils/ScalaTrySerializerUpgradeTest.java | 2 -
.../typeutils/EnumValueSerializerUpgradeTest.scala | 2 -
.../ScalaCaseClassSerializerUpgradeTest.scala | 2 -
flink-table/flink-table-calcite-bridge/pom.xml | 15 +-
.../org/apache/flink/table/catalog/Catalog.java | 125 +
.../ConnectionAlreadyExistException.java} | 29 +-
.../exceptions/ConnectionNotExistException.java | 46 +
.../stats/CatalogColumnStatisticsDataDate.java | 2 +-
.../stats/CatalogColumnStatisticsDataDouble.java | 2 +-
.../stats/CatalogColumnStatisticsDataLong.java | 2 +-
.../flink/table/factories/ConnectionFactory.java | 93 +
.../table/factories/DefaultConnectionFactory.java | 191 +
.../apache/flink/table/factories/FactoryUtil.java | 8 +
.../functions/BuiltInFunctionDefinitions.java | 149 +-
.../flink/table/functions/ChangelogFunction.java | 26 +
.../flink/table/functions/TableSemantics.java | 33 +
.../flink/table/secret/ReadableSecretStore.java | 5 +-
.../flink/table/secret/WritableSecretStore.java | 13 +-
.../table/types/inference/BuiltInCondition.java | 6 +-
.../table/types/inference/TraitCondition.java | 50 +
.../flink/table/types/inference/TraitContext.java | 17 +
.../table/types/inference/TypeInferenceUtil.java | 64 +-
.../strategies/ChangelogTypeStrategyUtils.java | 24 +
.../strategies/FromChangelogTypeStrategy.java | 74 +-
.../strategies/LateralSnapshotTypeStrategy.java | 234 +
.../strategies/RegexpExtractInputTypeStrategy.java | 24 +-
...eStrategy.java => RegexpInputTypeStrategy.java} | 48 +-
...gy.java => RegexpReplaceInputTypeStrategy.java} | 43 +-
.../strategies/SpecificInputTypeStrategies.java | 10 +
.../strategies/SpecificTypeStrategies.java | 4 +
.../types/inference/strategies/StrategyUtils.java | 32 +
.../strategies/ToChangelogTypeStrategy.java | 182 +-
.../types/logical/utils/LogicalTypeCasts.java | 25 +
.../apache/flink/table/utils/UpsertKeyUtils.java | 67 +
.../org.apache.flink.table.factories.Factory | 1 +
.../apache/flink/table/catalog/CatalogTest.java | 222 +
.../factories/DefaultConnectionFactoryTest.java | 392 +
.../flink/table/types/LogicalTypeCastsTest.java | 33 +-
.../FromChangelogInputTypeStrategyTest.java | 36 +-
.../LateralSnapshotInputTypeStrategyTest.java | 177 +
.../LateralSnapshotOutputTypeStrategyTest.java | 117 +
.../RegexpExtractInputTypeStrategyTest.java | 2 +-
...yTest.java => RegexpInputTypeStrategyTest.java} | 25 +-
...ava => RegexpReplaceInputTypeStrategyTest.java} | 38 +-
.../ToChangelogInputTypeStrategyTest.java | 133 +
.../ToChangelogOutputTypeStrategyTest.java | 168 +
.../types/inference/utils/TableSemanticsMock.java | 25 +
.../src/main/resources/META-INF/NOTICE | 6 +-
.../apache/calcite/jdbc/SimpleCalciteSchema.java | 56 +-
.../java/org/apache/calcite/rel/core/Join.java | 371 +
.../calcite/rel/metadata/RelMdPredicates.java | 1025 -
.../calcite/rel/rules/SubQueryRemoveRule.java | 125 +-
.../calcite/rel/type/RelDataTypeFactoryImpl.java | 59 +-
.../java/org/apache/calcite/rex/RexBuilder.java | 2231 ++
.../main/java/org/apache/calcite/rex/RexUtil.java | 322 +-
.../org/apache/calcite/runtime/SqlFunctions.java | 1243 +-
.../main/java/org/apache/calcite/sql/SqlCall.java | 252 -
.../calcite/sql/SqlGroupedWindowFunction.java | 46 +-
.../apache/calcite/sql/SqlIntervalQualifier.java | 115 +-
.../main/java/org/apache/calcite/sql/SqlUtil.java | 1366 -
.../apache/calcite/sql/fun/SqlCastFunction.java | 32 +-
.../calcite/sql/fun/SqlCoalesceFunction.java | 140 +
.../calcite/sql/fun/SqlMapValueConstructor.java | 45 +-
.../calcite/sql/fun/SqlStdOperatorTable.java | 2642 ++
.../org/apache/calcite/sql/type/BasicSqlType.java | 325 +
.../calcite/sql/type/SqlTypeAssignmentRule.java | 13 +-
.../calcite/sql/type/SqlTypeFactoryImpl.java | 87 +-
.../org/apache/calcite/sql/type/SqlTypeUtil.java | 218 +-
.../calcite/sql/validate/SqlValidatorImpl.java | 1183 +-
.../org/apache/calcite/sql2rel/AggConverter.java | 37 +-
.../apache/calcite/sql2rel/RelDecorrelator.java | 639 +-
.../apache/calcite/sql2rel/SqlToRelConverter.java | 1256 +-
.../calcite/sql2rel/StandardConvertletTable.java | 2173 --
.../planner/calcite/FlinkCalciteSqlValidator.java | 30 +
.../planner/calcite/FlinkConvertletTable.java | 22 +
.../table/planner/calcite/FlinkRexBuilder.java | 117 -
.../table/planner/calcite/FlinkTypeFactory.java | 876 +
.../table/planner/calcite/FlinkTypeSystem.java | 10 +
.../planner/calcite/RelTimeIndicatorConverter.java | 1 +
.../table/planner/connectors/DynamicSinkUtils.java | 8 +-
.../planner/connectors/DynamicSourceUtils.java | 6 +-
.../flink/table/planner/delegation/ParserImpl.java | 3 +-
.../expressions/converter/DirectConvertRule.java | 7 +-
.../functions/bridging/BridgingSqlFunction.java | 30 +-
.../functions/casting/RowToRowCastRule.java | 3 +
.../inference/CallBindingCallContext.java | 6 +
.../inference/OperatorBindingCallContext.java | 48 +-
.../functions/sql/FlinkSqlOperatorTable.java | 24 +-
.../planner/operations/SqlNodeConvertContext.java | 13 +-
.../operations/SqlNodeToOperationConversion.java | 58 +-
.../converters/SqlAlterViewAsConverter.java | 1 +
.../converters/SqlCreateViewConverter.java | 7 +-
.../operations/converters/SqlNodeConvertUtils.java | 60 +-
.../operations/converters/SqlNodeConverter.java | 7 +
.../AbstractCreateMaterializedTableConverter.java | 18 +-
.../SqlAlterMaterializedTableAsQueryConverter.java | 16 +-
...lAlterMaterializedTableDropSchemaConverter.java | 9 -
...SqlCreateOrAlterMaterializedTableConverter.java | 290 +-
.../plan/abilities/source/FilterPushDownSpec.java | 23 +-
.../source/MetadataFilterPushDownSpec.java | 59 +-
.../nodes/exec/serde/RexNodeJsonDeserializer.java | 62 +-
.../nodes/exec/serde/RexNodeJsonSerializer.java | 25 +-
.../plan/nodes/exec/spec/IntervalJoinSpec.java | 6 +-
.../exec/stream/StreamExecMiniBatchAssigner.java | 4 +-
.../stream/StreamExecProcessTableFunction.java | 38 +-
.../plan/nodes/exec/utils/CommonPythonUtil.java | 4 +-
.../nodes/logical/FlinkLogicalOverAggregate.java | 13 +
.../BatchPhysicalLocalRuntimeFilterBuilder.java | 5 +-
.../stream/StreamPhysicalProcessTableFunction.java | 19 +-
.../StreamNonDeterministicUpdatePlanVisitor.java | 88 +
.../plan/rules/logical/FlinkPruneEmptyRules.java | 194 -
.../logical/PushFilterIntoSourceScanRuleBase.java | 79 +-
.../logical/PushFilterIntoTableSourceScanRule.java | 52 +-
...WatermarkIntoTableSourceScanAcrossCalcRule.java | 2 +-
.../RemoveUnreachableCoalesceArgumentsRule.java | 212 -
.../plan/rules/logical/SubQueryDecorrelator.java | 13 +-
.../plan/rules/logical/WindowGroupReorderRule.java | 5 +-
.../plan/schema/TimeIndicatorRelDataType.java | 76 +
.../table/planner/plan/utils/UpsertKeyUtil.java | 23 +-
.../planner/utils/MaterializedTableUtils.java | 137 +-
.../src/main/resources/META-INF/NOTICE | 6 +-
...org.codehaus.commons.compiler.ICompilerFactory} | 2 +-
.../table/planner/calcite/FlinkTypeFactory.scala | 723 -
.../table/planner/codegen/ExprCodeGenerator.scala | 20 +
.../table/planner/codegen/ExpressionReducer.scala | 14 +-
.../codegen/ProcessTableRunnerGenerator.scala | 68 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 45 +-
.../planner/codegen/calls/StringCallGen.scala | 14 -
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 17 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 36 +-
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 5 +-
.../FlinkChangelogModeInferenceProgram.scala | 66 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 26 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 26 +-
.../PushProjectIntoLegacyTableSourceScanRule.scala | 2 +-
.../batch/BatchPhysicalOverAggregateRule.scala | 1 +
.../plan/schema/TimeIndicatorRelDataType.scala | 55 -
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 4 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 2 +-
.../planner/plan/utils/OverAggregateUtil.scala | 1 +
.../flink/table/planner/plan/utils/RankUtil.scala | 4 +-
.../planner/plan/utils/RexDefaultVisitor.scala | 4 +
.../planner/plan/utils/RexNodeExtractor.scala | 4 +
.../planner/plan/utils/TemporalJoinUtil.scala | 18 +-
.../table/api/QueryOperationSqlSemanticTest.java | 1 +
.../api/QueryOperationSqlSerializationTest.java | 2 +
.../table/api/QueryOperationTestPrograms.java | 63 +-
.../validation/MatchRecognizeValidationTest.java | 19 +
.../calcite/FlinkCalciteSqlValidatorTest.java | 32 +
.../planner/codegen/AsyncCodeGeneratorTest.java | 17 +-
.../codegen/AsyncCorrelateCodeGeneratorTest.java | 9 +-
.../planner/factories/TestValuesTableFactory.java | 1 +
.../planner/functions/CoalesceFunctionITCase.java | 301 +-
.../planner/functions/RegexpFunctionsITCase.java | 106 +
.../planner/functions/StringFunctionsITCase.java | 237 +-
.../operations/SqlCTASNodeToOperationTest.java | 10 +
.../operations/SqlDdlToOperationConverterTest.java | 41 +-
...erializedTableNodeToOperationConverterTest.java | 88 +-
.../SqlNodeToOperationConversionTestBase.java | 6 +-
...erationConvertTableToMaterializedTableTest.java | 663 +
...reateOrAlterMaterializedTableConverterTest.java | 6 +-
.../SqlRTASNodeToOperationConverterTest.java | 10 +
.../planner/plan/batch/sql/RowLevelUpdateTest.java | 7 +-
.../plan/nodes/exec/common/CalcTestPrograms.java | 73 +
.../nodes/exec/common/CommonExecSinkITCase.java | 11 +-
.../nodes/exec/common/CorrelateTestPrograms.java | 4 +-
.../exec/common/JoinSemanticTestPrograms.java | 195 +
.../nodes/exec/serde/RexNodeJsonSerdeTest.java | 5 +-
.../plan/nodes/exec/stream/CalcRestoreTest.java | 3 +-
.../exec/stream/FromChangelogRestoreTest.java | 5 +-
.../exec/stream/FromChangelogSemanticTests.java | 1 +
.../exec/stream/FromChangelogTestPrograms.java | 97 +
.../plan/nodes/exec/stream/JoinSemanticTests.java | 8 +-
.../plan/nodes/exec/stream/MiscSemanticTests.java | 3 +-
.../stream/ProcessTableFunctionSemanticTests.java | 15 +-
.../stream/ProcessTableFunctionTestPrograms.java | 21 +
.../exec/stream/ProcessTableFunctionTestUtils.java | 46 +
.../exec/stream/TemporalJoinTestPrograms.java | 4 +-
.../nodes/exec/stream/ToChangelogRestoreTest.java | 7 +-
.../exec/stream/ToChangelogSemanticTests.java | 10 +-
.../nodes/exec/stream/ToChangelogTestPrograms.java | 371 +-
.../plan/nodes/exec/testutils/RestoreTestBase.java | 52 +-
.../MetadataFilterInReadingMetadataTest.java | 264 +-
.../logical/MetadataFilterResultShapesITCase.java | 305 +
...RemoveUnreachableCoalesceArgumentsRuleTest.java | 5 +-
...plifyCoalesceWithEquiJoinConditionRuleTest.java | 26 +
.../planner/plan/stream/sql/FromChangelogTest.java | 26 +
.../plan/stream/sql/ProcessTableFunctionTest.java | 121 +-
.../plan/stream/sql/SnapshotTableFunctionTest.java | 171 +
.../planner/plan/stream/sql/ToChangelogTest.java | 78 +
.../table/planner/plan/utils/AsyncUtilTest.java | 11 +-
.../utils/ValidateAndExtractColumnChangesTest.java | 281 +
.../table/planner/plan/batch/sql/CalcTest.xml | 4 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 8 +-
.../plan/batch/sql/DynamicFunctionPlanTest.xml | 18 +-
.../plan/batch/sql/ForwardHashExchangeTest.xml | 8 +-
.../planner/plan/batch/sql/RemoveCollationTest.xml | 4 +-
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 70 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 4 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 8 +-
.../table/planner/plan/batch/sql/TableSinkTest.xml | 10 +-
.../table/planner/plan/batch/sql/ValuesTest.xml | 3 +-
.../plan/batch/sql/agg/GroupingSetsTest.xml | 4 +-
.../plan/batch/sql/agg/OverAggregateTest.xml | 54 +-
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 85 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 49 +-
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 127 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 127 +-
.../table/planner/plan/batch/table/CalcTest.xml | 4 +-
.../plan/hints/batch/BroadcastJoinHintTest.xml | 88 +-
.../plan/hints/batch/NestLoopJoinHintTest.xml | 88 +-
.../plan/hints/batch/ShuffleHashJoinHintTest.xml | 90 +-
.../plan/hints/batch/ShuffleMergeJoinHintTest.xml | 90 +-
.../table/planner/plan/optimize/ScanReuseTest.xml | 26 +-
.../logical/AggregateReduceFunctionsRuleTest.xml | 4 +-
.../rules/logical/ConvertToNotInOrInRuleTest.xml | 22 +-
.../rules/logical/FlinkPruneEmptyRulesTest.xml | 6 +-
.../logical/JoinConditionTypeCoerceRuleTest.xml | 2 +-
.../MetadataFilterInReadingMetadataTest.xml | 52 +-
.../PushFilterInCalcIntoTableSourceRuleTest.xml | 6 +-
.../PushFilterIntoTableSourceScanRuleTest.xml | 8 +-
.../PushProjectIntoTableSourceScanRuleTest.xml | 4 +-
.../RemoveUnreachableCoalesceArgumentsRuleTest.xml | 10 +-
.../ReplaceIntersectWithSemiJoinRuleTest.xml | 2 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.xml | 2 +-
...mplifyCoalesceWithEquiJoinConditionRuleTest.xml | 16 +-
.../logical/SimplifyJoinConditionRuleTest.xml | 2 +-
.../rules/logical/WindowGroupReorderRuleTest.xml | 32 +-
.../logical/subquery/SubQueryAntiJoinTest.xml | 184 +-
.../logical/subquery/SubQuerySemiJoinTest.xml | 327 +-
.../SubqueryCorrelateVariablesValidationTest.xml | 2 +-
.../PushLocalAggIntoTableSourceScanRuleTest.xml | 4 +-
.../PushCalcPastChangelogNormalizeRuleTest.xml | 18 +-
.../table/planner/plan/stream/sql/CalcTest.xml | 22 +-
.../planner/plan/stream/sql/DeltaJoinTest.xml | 4 +-
.../plan/stream/sql/FilterableSourceTest.xml | 2 +-
.../planner/plan/stream/sql/FromChangelogTest.xml | 20 +
.../planner/plan/stream/sql/MatchRecognizeTest.xml | 4 +-
.../plan/stream/sql/ProcessTableFunctionTest.xml | 66 +
.../table/planner/plan/stream/sql/RankTest.xml | 105 +
.../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +-
.../plan/stream/sql/SnapshotTableFunctionTest.xml | 73 +
.../planner/plan/stream/sql/ToChangelogTest.xml | 98 +-
.../table/planner/plan/stream/sql/ValuesTest.xml | 3 +-
.../planner/plan/stream/sql/agg/AggregateTest.xml | 4 +-
.../plan/stream/sql/agg/GroupingSetsTest.xml | 4 +-
.../plan/stream/sql/agg/OverAggregateTest.xml | 46 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 4 +-
.../planner/plan/stream/sql/join/JoinTest.xml | 86 +-
.../table/planner/plan/stream/table/ValuesTest.xml | 76 +-
.../plan/calc-coalesce-nested-row-left-join.json | 284 +
.../calc-coalesce/plan/calc-coalesce.json | 135 +
.../calc-coalesce/savepoint/_metadata | Bin 0 -> 8194 bytes
.../plan/calc-current-timestamp.json | 38 +-
.../calc-current-timestamp/savepoint/_metadata | Bin 5868 -> 5860 bytes
...om-changelog-retract-partition-by-restore.json} | 59 +-
.../savepoint/_metadata | Bin 0 -> 12564 bytes
.../plan/from-changelog-retract-restore.json | 3 -
...rom-changelog-upsert-partition-by-restore.json} | 100 +-
.../savepoint/_metadata | Bin 0 -> 9805 bytes
.../plan/process-late-events-restore.json | 2 -
.../plan/process-map-state-restore.json | 1 -
.../plan/process-multi-input-restore.json | 2 -
.../plan/process-multi-state-restore.json | 1 -
.../process-partitioned-named-timers-restore.json | 1 -
.../plan/process-row-semantic-table-restore.json | 2 -
.../process-updating-output-upsert-restore.json | 1 -
...to-changelog-retract-partition-by-restore.json} | 64 +-
.../savepoint/_metadata | Bin 0 -> 13814 bytes
...-retract-produces-partial-deletes-restore.json} | 38 +-
.../savepoint/_metadata | Bin 0 -> 8271 bytes
.../plan/to-changelog-retract-restore.json | 13 +-
.../to-changelog-upsert-partition-by-restore.json} | 127 +-
.../savepoint/_metadata | Bin 0 -> 18497 bytes
.../plan/to-changelog-upsert-restore.json} | 78 +-
.../savepoint/_metadata | Bin 0 -> 12994 bytes
.../table/planner/catalog/CatalogTableITCase.scala | 2 +-
.../planner/expressions/ScalarFunctionsTest.scala | 162 -
.../planner/expressions/SqlExpressionTest.scala | 1 +
.../batch/sql/join/BroadcastHashJoinTest.scala | 7 +
.../plan/batch/sql/join/ShuffledHashJoinTest.scala | 7 +
.../plan/batch/sql/join/SortMergeJoinTest.scala | 6 +
.../table/validation/AggregateValidationTest.scala | 26 +-
.../table/validation/CalcValidationTest.scala | 6 +-
.../table/validation/JoinValidationTest.scala | 2 +-
.../metadata/AggCallSelectivityEstimatorTest.scala | 2 +-
.../metadata/FlinkRelMdColumnIntervalTest.scala | 38 +-
.../metadata/FlinkRelMdColumnNullCountTest.scala | 11 +-
.../FlinkRelMdColumnOriginNullCountTest.scala | 11 +-
.../metadata/FlinkRelMdColumnUniquenessTest.scala | 4 +-
.../metadata/FlinkRelMdDistinctRowCountTest.scala | 5 +-
.../plan/metadata/FlinkRelMdDistributionTest.scala | 18 +-
.../FlinkRelMdFilteredColumnIntervalTest.scala | 5 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 421 +-
.../FlinkRelMdModifiedMonotonicityTest.scala | 35 +-
.../plan/metadata/FlinkRelMdRowCollationTest.scala | 24 +-
.../plan/metadata/FlinkRelMdRowCountTest.scala | 4 +-
.../plan/metadata/FlinkRelMdSelectivityTest.scala | 30 +-
.../planner/plan/metadata/FlinkRelMdSizeTest.scala | 106 +-
.../plan/metadata/FlinkRelMdUniqueGroupsTest.scala | 24 +-
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 173 +-
.../plan/metadata/FlinkRelMdUpsertKeysTest.scala | 239 +-
.../rules/logical/FlinkPruneEmptyRulesTest.scala | 10 +-
.../logical/subquery/SubQueryAntiJoinTest.scala | 16 +-
.../logical/subquery/SubQuerySemiJoinTest.scala | 98 +-
.../plan/schema/TimeIndicatorRelDataTypeTest.scala | 2 +-
.../table/planner/plan/stream/sql/CalcTest.scala | 8 +
.../plan/stream/sql/FilterableSourceTest.scala | 2 +-
.../plan/stream/sql/NonDeterministicDagTest.scala | 244 +
.../table/planner/plan/stream/sql/RankTest.scala | 103 +-
.../plan/stream/sql/agg/OverAggregateTest.scala | 45 +-
.../planner/runtime/batch/sql/CalcITCase.scala | 35 +
.../runtime/batch/sql/join/LookupJoinITCase.scala | 2 +-
.../runtime/batch/table/AggregationITCase.scala | 2 +-
.../planner/runtime/batch/table/CalcITCase.scala | 6 +-
.../runtime/batch/table/DecimalITCase.scala | 20 -
.../runtime/stream/sql/TemporalJoinITCase.scala | 2 +-
.../planner/runtime/stream/table/JoinITCase.scala | 4 +-
.../planner/runtime/utils/StreamTestSink.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 44 +-
.../planner/utils/UserDefinedAggFunctions.scala | 2 +-
.../utils/UserDefinedTableAggFunctions.scala | 8 +-
.../planner/utils/UserDefinedTableFunctions.scala | 2 +-
.../table/data/binary/BinaryStringDataUtil.java | 115 -
.../table/runtime/functions/SqlFunctionUtils.java | 96 +-
.../runtime/functions/ptf/ToChangelogFunction.java | 119 +-
.../join/temporal/TemporalRowTimeJoinOperator.java | 32 +-
.../operators/process/RuntimeTableSemantics.java | 11 +-
.../ProcTimeMiniBatchAssignerOperator.java | 2 +-
....java => RowTimeMiniBatchAssignerOperator.java} | 4 +-
.../linked/LinkedMultiSetState.java | 4 +-
.../linked/RowDataKeySerializerSnapshot.java | 6 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
.../flink/table/data/BinaryStringDataTest.java | 132 -
.../temporal/TemporalRowTimeJoinOperatorTest.java | 113 +-
...essSetTableOperatorInterruptibleTimersTest.java | 3 +-
...a => RowTimeMiniBatchAssignerOperatorTest.java} | 8 +-
.../SequencedMultiSetStateTest.java | 28 +
.../linked/RowDataKeySerializerTest.java | 57 +
.../table/runtime/functions/InvocationContext.java | 65 +
.../runtime/functions/ListViewStateConverter.java | 79 +
.../runtime/functions/MapViewStateConverter.java | 92 +
.../functions/ProcessTableFunctionTestHarness.java | 1503 +-
.../table/runtime/functions/ResolvedMethod.java | 60 +
.../table/runtime/functions/RowStateConverter.java | 60 +
.../table/runtime/functions/StateConverter.java | 33 +-
.../functions/StructuredTypeStateConverter.java | 67 +
.../runtime/functions/TestHarnessCallContext.java | 9 +-
.../functions/TestHarnessDataTypeFactory.java | 4 +-
.../runtime/functions/TestHarnessStateManager.java | 236 +
.../functions/TestHarnessTableSemantics.java | 25 +-
.../runtime/functions/TestHarnessTimerManager.java | 181 +
.../flink/table/runtime/functions/Timer.java | 135 +
.../ProcessTableFunctionTestHarnessTest.java | 1800 +-
.../functions/TestHarnessTimerManagerTest.java | 369 +
flink-table/pom.xml | 9 +-
.../testframe/container/FlinkImageBuilder.java | 2 +
.../source/reader/TestingReaderContext.java | 10 +
.../reader/TestingSplitEnumeratorContext.java | 10 +
.../testutils/catalog/TestFileSystemCatalog.java | 58 +-
.../{FailsOnJava11.java => FailsOnJava25.java} | 4 +-
.../org/apache/flink/util/DockerImageVersions.java | 6 +-
.../java/org/apache/flink/test/util/TestUtils.java | 15 +-
.../org/apache/flink/test/util/TestUtilsTest.java | 60 +
flink-tests/pom.xml | 5 +-
.../jobmaster/JobMasterTriggerSavepointITCase.java | 17 +-
.../CheckpointAcknowledgeFailureITCase.java | 200 +
.../MapStateNullValueCheckpointingITCase.java | 139 +
.../flink/test/checkpointing/SavepointITCase.java | 10 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 11 +-
.../flink/test/runtime/IPv6HostnamesITCase.java | 45 +-
.../restore/AbstractOperatorRestoreTestBase.java | 60 +-
.../streaming/runtime/GlobalAggregateITCase.java | 2 +-
flink-yarn-tests/pom.xml | 4 +
.../java/org/apache/flink/yarn/YarnTestBase.java | 3 +-
.../org/apache/flink/yarn/YarnTestBaseTest.java | 23 +
flink-yarn/pom.xml | 8 +
pom.xml | 83 +-
tools/azure-pipelines/build-apache-repo.yml | 4 +-
tools/azure-pipelines/build-nightly-dist.yml | 6 +-
tools/azure-pipelines/free_disk_space.sh | 36 +-
tools/ci/deploy_nightly_to_s3.sh | 42 +-
.../tools/ci/licensecheck/JarFileChecker.java | 7 +
tools/releasing/create_release_branch.sh | 5 +
876 files changed, 52943 insertions(+), 39258 deletions(-)
create mode 100644 docs/content.zh/release-notes/flink-2.3.md
rename flink-end-to-end-tests/test-scripts/{common_s3_minio.sh => common_s3_seaweedfs.sh} (63%)
copy {flink-clients => flink-examples/flink-examples-streaming}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (100%)
copy flink-filesystems/{flink-fs-hadoop-shaded/src/main/resources/META-INF/licenses/LICENSE-stax2api => flink-gs-fs-hadoop/src/main/resources/META-INF/licenses/LICENSE.stax2-api} (100%)
create mode 100644 flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/GSFileSystemBehaviorITCase.java
create mode 100644 flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/GSRecoverableWriterITCase.java
create mode 100644 flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/GSTestCredentials.java
rename flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/{HAApplicationRunOnMinioS3StoreITCase.java => HAApplicationRunOnSeaweedFsS3StoreITCase.java} (84%)
rename flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/{HAJobRunOnMinioS3StoreITCase.java => HAJobRunOnSeaweedFsS3StoreITCase.java} (84%)
rename flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/{S5CmdOnMinioITCase.java => S5CmdOnSeaweedFsITCase.java} (93%)
rename flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/{MinioTestContainer.java => SeaweedFsTestContainer.java} (83%)
rename flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/{MinioTestContainerTest.java => SeaweedFsTestContainerTest.java} (89%)
create mode 100644 flink-filesystems/flink-s3-fs-native/src/test/java/org/apache/flink/fs/s3native/writer/InMemoryNativeS3Operations.java
create mode 100644 flink-filesystems/flink-s3-fs-native/src/test/java/org/apache/flink/fs/s3native/writer/NativeS3RecoverableWriterRecoveryTest.java
copy {flink-clients => flink-fs-tests}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (100%)
copy flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ToChangelogRestoreTest.java => flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/filter/BoundInfo.java (56%)
copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dml/SqlEndStatementSet.java => flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/filter/EmptyKeyFilter.java (51%)
create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/filter/ExactKeyFilter.java
create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/filter/RangeKeyFilter.java
create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/filter/SavepointKeyFilter.java
create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/FilteringCloseableIterator.java
create mode 100644 flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointFilterTranslator.java
create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/input/FilteringCloseableIteratorTest.java
create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/table/SavepointFilterTranslatorTest.java
copy flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/{HistoryServerStaticFileServerHandler.java => AbstractHistoryServerHandler.java} (62%)
create mode 100644 flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchiveStorage.java
create mode 100644 flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/FileArchiveStorage.java
create mode 100644 flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerRocksDBHandler.java
create mode 100644 flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/RocksDBArchiveStorage.java
create mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/AbstractHistoryServerHandlerTest.java
create mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/ArchiveStorageTest.java
delete mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandlerTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/api/connector/source/RichSourceReaderContextTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/files/StaticFileServerHandlerTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/JobExceptionsMessageParametersTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableConversionITCase.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableTestUtils.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/SqlJoin.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/fun/SqlJsonQueryFunction.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/type/SqlTypeFamily.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/type/SqlTypeName.java
create mode 100644 flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/DeepCopyUnparsingTesterImpl.java
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/AlterConnectionEvent.java
copy flink-runtime-web/web-dashboard/src/app/pages/application/application-detail/status/application-status.component.less => flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/ConnectionModificationEvent.java (62%)
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CreateConnectionEvent.java
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/DropConnectionEvent.java
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/ConvertTableToMaterializedTableOperation.java
create mode 100644 flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableAsQueryOperationValidationTest.java
create mode 100644 flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperationValidationTest.java
create mode 100644 flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/operations/materializedtable/MaterializedTableChangeHandlerTest.java
rename flink-table/{flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/CoalesceFunction.java => flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/ConnectionAlreadyExistException.java} (52%)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/ConnectionNotExistException.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/ConnectionFactory.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/DefaultConnectionFactory.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LateralSnapshotTypeStrategy.java
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{RegexpExtractInputTypeStrategy.java => RegexpInputTypeStrategy.java} (59%)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{RegexpExtractInputTypeStrategy.java => RegexpReplaceInputTypeStrategy.java} (63%)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/UpsertKeyUtils.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/DefaultConnectionFactoryTest.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/LateralSnapshotInputTypeStrategyTest.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/LateralSnapshotOutputTypeStrategyTest.java
copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/{RegexpExtractInputTypeStrategyTest.java => RegexpInputTypeStrategyTest.java} (77%)
copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/{RegexpExtractInputTypeStrategyTest.java => RegexpReplaceInputTypeStrategyTest.java} (67%)
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ToChangelogInputTypeStrategyTest.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ToChangelogOutputTypeStrategyTest.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Join.java
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/metadata/RelMdPredicates.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexBuilder.java
delete mode 100755 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlCall.java
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlUtil.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/fun/SqlCoalesceFunction.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/fun/SqlStdOperatorTable.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/type/BasicSqlType.java
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkTypeFactory.java
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkPruneEmptyRules.java
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/RemoveUnreachableCoalesceArgumentsRule.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/schema/TimeIndicatorRelDataType.java
copy flink-table/{flink-table-common/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory => flink-table-planner/src/main/resources/META-INF/services/org.codehaus.commons.compiler.ICompilerFactory} (94%)
delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala
delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/schema/TimeIndicatorRelDataType.scala
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConvertTableToMaterializedTableTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/MetadataFilterResultShapesITCase.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/SnapshotTableFunctionTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/ValidateAndExtractColumnChangesTest.java
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/SnapshotTableFunctionTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-calc_1/calc-coalesce-nested-row-left-join/plan/calc-coalesce-nested-row-left-join.json
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-calc_1/calc-coalesce/plan/calc-coalesce.json
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-calc_1/calc-coalesce/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{from-changelog-retract-restore/plan/from-changelog-retract-restore.json => from-changelog-retract-partition-by-restore/plan/from-changelog-retract-partition-by-restore.json} (74%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-retract-partition-by-restore/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{from-changelog-retract-restore/plan/from-changelog-retract-restore.json => from-changelog-upsert-partition-by-restore/plan/from-changelog-upsert-partition-by-restore.json} (53%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/from-changelog-upsert-partition-by-restore/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{to-changelog-retract-restore/plan/to-changelog-retract-restore.json => to-changelog-retract-partition-by-restore/plan/to-changelog-retract-partition-by-restore.json} (68%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/to-changelog-retract-partition-by-restore/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{to-changelog-retract-restore/plan/to-changelog-retract-restore.json => to-changelog-retract-produces-partial-deletes-restore/plan/to-changelog-retract-produces-partial-deletes-restore.json} (83%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/to-changelog-retract-produces-partial-deletes-restore/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{process-multi-input-restore/plan/process-multi-input-restore.json => to-changelog-upsert-partition-by-restore/plan/to-changelog-upsert-partition-by-restore.json} (56%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/to-changelog-upsert-partition-by-restore/savepoint/_metadata
copy flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{to-changelog-retract-restore/plan/to-changelog-retract-restore.json => to-changelog-upsert-restore/plan/to-changelog-upsert-restore.json} (67%)
create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/to-changelog-upsert-restore/savepoint/_metadata
rename flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/{RowTimeMiniBatchAssginerOperator.java => RowTimeMiniBatchAssignerOperator.java} (97%)
rename flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/{RowTimeMiniBatchAssginerOperatorTest.java => RowTimeMiniBatchAssignerOperatorTest.java} (93%)
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/InvocationContext.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/ListViewStateConverter.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/MapViewStateConverter.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/ResolvedMethod.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/RowStateConverter.java
copy flink-runtime-web/web-dashboard/src/app/pages/application/application-detail/status/application-status.component.less => flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/StateConverter.java (56%)
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/StructuredTypeStateConverter.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessTimerManager.java
create mode 100644 flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/Timer.java
create mode 100644 flink-table/flink-table-test-utils/src/test/java/org/apache/flink/table/runtime/functions/TestHarnessTimerManagerTest.java
rename flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/{FailsOnJava11.java => FailsOnJava25.java} (90%)
create mode 100644 flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/test/util/TestUtilsTest.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAcknowledgeFailureITCase.java