This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/uv/flink-python/docs/urllib3-2.7.0
in repository https://gitbox.apache.org/repos/asf/flink.git
discard 8c15883f31d Bump urllib3 from 2.6.3 to 2.7.0 in /flink-python/docs
add 07958d75456 [FLINK-39396][table] Simplify early return condition in
`SqlLikeChainChecker`
add 7b1b171640e [FLINK-39644][s3] Upgrade aws sdk version to 2.44.x to add
enhanced S3 Transfer Manager performance
add e4b8e035fa0 [FLINK-39632][table] Add fromChangelog() / toChangelog()
convenience methods to PartitionedTable (#28128)
add aa079c5bab9 [FLINK-39649][table] `REGEXP_EXTRACT` plan-time validation
and hot-path log cleanup
add 6b43241400d [FLINK-39607][s3] Add missing Nullable annotation and
precondition for config
add 23a93fb0265 [hotfix][flink-connector-base] Fix duplicated dependency &
plugin (#28024)
add 7fc6ca1d19d [hotfix][docs] Bump externalized connector docs refs to
latest minor releases (#28095)
add 6c60f4fee2a [hotfix][build] Concurrent runs for PR should be cancelled
add 1990310135e [FLINK-39672][docs] Document Java records as supported
POJO types
add d58d0a4092b [hotfix][build] Use sparse-checkout paths for Flink
template in GHA
add 7045ec893fa [hotfix] Fix missing eslint enforcement under `runtime-web`
add 92886f2e975 [FLINK-39166][s3] Add bucket-level configuration support
to Native S3 FileSystem
add c43029e5b4a [FLINK-39671][model-triton] Drop redundant jackson version
pins; inherit BOM
add 80be7e48b82 [hotfix][state/tests] Dispose keyed state backend in
testMapStateWithNullValue
add a49eca81067 [FLINK-39647] Downgrade presto-hive to 0.294
add 334e01f0a48 [FLINK-39616][docs] Document ORDER BY usage with
FROM_CHANGELOG (#28166)
add b5a1575f4b4 [FLINK-39666][table] Fix edge-case bugs in
TO_TIMESTAMP_LTZ precision handling
add 1c61abced02 [FLINK-30514][connector-base] Fix HybridSourceReader's
method calling order for underlying subsources during source switch
add 2ad33c6b79a [hotfix][flink-tests] Fix duplicated dependency & plugin
(#28023)
add 5d948d82508 [FLINK-39377][table] Add initial implementation of
ProcessTableFunctionTestHarness (#27928)
add 92fabc688e1 [hotfix][ci] Bump artifact-upload version
add f1d36222ccf [FLINK-39663][table] Support `ALTER MATERIALIZED TABLE ...
RESET (...)` conversion
add f008d0ee0ab [FLINK-39685][table] Redact sensitive options in SHOW
CREATE and DESCRIBE CATALOG statements
add 127f387c391 [FLINK-39503][runtime-web] Auto-fit "Job Overview" DAG
height and add recenter control
add b50d5f0e2c4 [hotfix] Bump download-artifact action to v8 as GHA
requires
add 1e6a73616eb [FLINK-22543][runtime-web] Fix Exception History table
layout broken by long exception strings
add 04a226ec4fb [hotfix] Fix misprint in upload artifact condition
add 9a72fde4824 [FLINK-39662][table] Support `ALTER MATERIALIZED TABLE ...
SET (...)` conversion
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 e95fccc2ada Bump urllib3 from 2.6.3 to 2.7.0 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 (8c15883f31d)
\
N -- N -- N
refs/heads/dependabot/uv/flink-python/docs/urllib3-2.7.0 (e95fccc2ada)
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/ci.yml | 4 +
.github/workflows/docs-legacy.yml | 4 +-
.github/workflows/docs.yml | 10 +-
.github/workflows/nightly-trigger.yml | 43 +-
.github/workflows/nightly.yml | 6 +-
.github/workflows/template.flink-ci.yml | 45 +-
.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 +
.../docs/deployment/java_compatibility.md | 3 +
.../content.zh/docs/deployment/metric_reporters.md | 2 +-
.../docs/dev/datastream/application_parameters.md | 5 +-
.../serialization/schema_evolution.md | 2 +
.../serialization/types_serialization.md | 7 +
.../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 | 670 +
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 | 188 +
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/java_compatibility.md | 3 +
docs/content/docs/deployment/metric_reporters.md | 2 +-
.../docs/dev/datastream/application_parameters.md | 9 +-
docs/content/docs/dev/datastream/execution_mode.md | 6 +-
.../serialization/schema_evolution.md | 2 +
.../serialization/types_serialization.md | 7 +
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 | 674 +-
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 | 188 +
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 | 236 +-
docs/content/docs/sql/reference/queries/joins.md | 2 +
docs/content/release-notes/flink-2.3.md | 290 +-
docs/data/sql_functions.yml | 59 +-
docs/data/sql_functions_zh.yml | 58 +-
.../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 | 8 +-
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 +-
flink-connectors/flink-connector-base/pom.xml | 7 -
.../base/source/hybrid/HybridSourceReader.java | 18 +-
.../source/hybrid/HybridSourceSplitEnumerator.java | 6 +
.../FutureCompletingBlockingQueue.java | 18 +-
.../base/source/hybrid/HybridSourceReaderTest.java | 50 +
.../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 | 109 +-
flink-filesystems/flink-s3-fs-native/pom.xml | 4 +-
.../flink/fs/s3native/BucketConfigProvider.java | 202 +
.../flink/fs/s3native/NativeS3FileSystem.java | 14 +-
.../fs/s3native/NativeS3FileSystemFactory.java | 111 +-
.../flink/fs/s3native/NativeS3OutputStream.java | 9 +-
.../apache/flink/fs/s3native/S3BucketConfig.java | 342 +
.../apache/flink/fs/s3native/S3ClientProvider.java | 269 +-
.../NativeS3RecoverableFsDataOutputStream.java | 23 +-
.../s3native/writer/NativeS3RecoverableWriter.java | 107 +-
.../src/main/resources/META-INF/NOTICE | 92 +-
.../fs/s3native/BucketConfigProviderTest.java | 259 +
.../fs/s3native/NativeS3FileSystemFactoryTest.java | 239 +-
.../flink/fs/s3native/S3BucketConfigTest.java | 170 +
.../flink/fs/s3native/S3ClientProviderTest.java | 68 +
.../writer/InMemoryNativeS3Operations.java | 165 +
.../NativeS3RecoverableWriterRecoveryTest.java | 349 +
flink-filesystems/flink-s3-fs-presto/pom.xml | 10 +-
.../src/main/resources/META-INF/NOTICE | 22 +-
...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 | 55 +-
.../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-models/flink-model-triton/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 6 +-
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/expressions.py | 21 +-
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 | 8 +-
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/.eslintignore | 6 +-
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-icons.ts | 4 +-
.../web-dashboard/src/app/app.interceptor.ts | 2 +-
.../src/app/components/dagre/dagre.component.html | 12 +
.../src/app/components/dagre/dagre.component.less | 10 +
.../src/app/components/dagre/dagre.component.ts | 15 +-
.../status/application-status.component.html | 7 +-
.../status/application-status.component.less | 13 +-
.../status/application-status.component.ts | 2 +
.../job-manager/logs/job-manager-logs.component.ts | 32 +-
.../job/exceptions/job-exceptions.component.html | 11 +-
.../job/exceptions/job-exceptions.component.less | 14 +-
.../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 | 13 +-
.../logs/task-manager-logs.component.ts | 36 +-
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 +
.../flink/runtime/state/StateBackendTestBase.java | 36 +-
.../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 | 67 +-
.../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 +-
.../org/apache/flink/table/api/Expressions.java | 89 +-
.../apache/flink/table/api/PartitionedTable.java | 121 +
.../java/org/apache/flink/table/api/Table.java | 32 +-
.../flink/table/api/config/TableConfigOptions.java | 15 +
.../flink/table/api/internal/ShowCreateUtil.java | 67 +-
.../table/api/internal/TableEnvironmentImpl.java | 7 +
.../apache/flink/table/api/internal/TableImpl.java | 11 +
.../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 +
.../table/operations/DescribeCatalogOperation.java | 19 +-
.../operations/ShowCreateCatalogOperation.java | 6 +-
.../ShowCreateMaterializedTableOperation.java | 4 +-
.../table/operations/ShowCreateModelOperation.java | 7 +-
.../table/operations/ShowCreateTableOperation.java | 4 +-
.../flink/table/operations/SortQueryOperation.java | 25 +-
.../AlterMaterializedTableChangeOperation.java | 147 +-
.../ConvertTableToMaterializedTableOperation.java | 107 +
.../FullAlterMaterializedTableOperation.java | 14 +-
.../MaterializedTableChangeHandler.java | 150 +-
.../flink/table/api/TableEnvironmentTest.java | 1 +
.../table/api/internal/ShowCreateUtilTest.java | 107 +-
.../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 +
.../flink/table/catalog/DefaultCatalogModel.java | 4 +-
.../flink/table/catalog/DefaultCatalogTable.java | 3 +-
.../ConnectionAlreadyExistException.java | 52 +-
.../exceptions/ConnectionNotExistException.java | 46 +
.../stats/CatalogColumnStatisticsDataDate.java | 2 +-
.../stats/CatalogColumnStatisticsDataDouble.java | 2 +-
.../stats/CatalogColumnStatisticsDataLong.java | 2 +-
.../table/expressions/ValueLiteralExpression.java | 16 +-
.../flink/table/factories/ConnectionFactory.java | 93 +
.../table/factories/DefaultConnectionFactory.java | 191 +
.../apache/flink/table/factories/FactoryUtil.java | 8 +
.../functions/BuiltInFunctionDefinitions.java | 163 +-
.../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 | 95 +
.../strategies/RegexpInputTypeStrategy.java | 83 +
.../strategies/RegexpReplaceInputTypeStrategy.java | 88 +
.../strategies/SpecificInputTypeStrategies.java | 13 +
.../strategies/SpecificTypeStrategies.java | 4 +
.../types/inference/strategies/StrategyUtils.java | 32 +
.../strategies/ToChangelogTypeStrategy.java | 182 +-
.../strategies/ToTimestampLtzTypeStrategy.java | 61 +-
.../types/logical/utils/LogicalTypeCasts.java | 25 +
.../apache/flink/table/utils/DateTimeUtils.java | 62 +-
.../apache/flink/table/utils/UpsertKeyUtils.java | 67 +
.../org.apache.flink.table.factories.Factory | 1 +
.../apache/flink/table/catalog/CatalogTest.java | 222 +
.../table/catalog/DefaultCatalogTableTest.java | 84 +
.../flink/table/expressions/ExpressionTest.java | 10 +-
.../factories/DefaultConnectionFactoryTest.java | 392 +
.../flink/table/types/LogicalTypeCastsTest.java | 33 +-
.../FromChangelogInputTypeStrategyTest.java | 36 +-
.../LateralSnapshotInputTypeStrategyTest.java | 177 +
.../LateralSnapshotOutputTypeStrategyTest.java | 117 +
.../RegexpExtractInputTypeStrategyTest.java | 60 +
.../strategies/RegexpInputTypeStrategyTest.java | 57 +
.../RegexpReplaceInputTypeStrategyTest.java | 64 +
.../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 | 9 +-
.../functions/bridging/BridgingSqlFunction.java | 30 +-
.../functions/casting/RowToRowCastRule.java | 3 +
.../inference/CallBindingCallContext.java | 6 +
.../inference/OperatorBindingCallContext.java | 48 +-
.../functions/sql/FlinkSqlOperatorTable.java | 38 +-
.../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 +
.../operations/converters/SqlNodeConverters.java | 4 +
.../AbstractCreateMaterializedTableConverter.java | 18 +-
.../SqlAlterMaterializedTableAsQueryConverter.java | 16 +-
...lAlterMaterializedTableDropSchemaConverter.java | 9 -
.../SqlAlterMaterializedTableOptionsConverter.java | 64 +
.../SqlAlterMaterializedTableResetConverter.java | 75 +
...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 | 23 +
.../table/planner/codegen/ExpressionReducer.scala | 14 +-
.../codegen/ProcessTableRunnerGenerator.scala | 68 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 45 +-
.../planner/codegen/calls/StringCallGen.scala | 16 -
.../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 +
.../table/planner/catalog/DescribeCatalogTest.java | 81 +
.../planner/codegen/AsyncCodeGeneratorTest.java | 17 +-
.../codegen/AsyncCorrelateCodeGeneratorTest.java | 9 +-
.../planner/factories/TestValuesTableFactory.java | 1 +
.../planner/functions/CoalesceFunctionITCase.java | 301 +-
.../planner/functions/LikeFunctionITCase.java | 16 +-
.../planner/functions/RegexpFunctionsITCase.java | 144 +-
.../planner/functions/StringFunctionsITCase.java | 237 +-
.../planner/functions/TimeFunctionsITCase.java | 129 +
.../operations/SqlCTASNodeToOperationTest.java | 10 +
.../operations/SqlDdlToOperationConverterTest.java | 41 +-
...erializedTableNodeToOperationConverterTest.java | 169 +-
.../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 | 2 +
.../exec/stream/FromChangelogTestPrograms.java | 128 +
.../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 | 11 +-
.../nodes/exec/stream/ToChangelogTestPrograms.java | 401 +-
.../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 | 118 +-
.../runtime/functions/SqlLikeChainChecker.java | 19 +-
.../runtime/functions/ptf/ToChangelogFunction.java | 119 +-
.../runtime/functions/scalar/CoalesceFunction.java | 43 -
.../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 +
flink-table/flink-table-test-utils/pom.xml | 11 +-
.../table/runtime/functions/InvocationContext.java | 65 +
.../runtime/functions/ListViewStateConverter.java | 79 +
.../runtime/functions/MapViewStateConverter.java | 92 +
.../functions/ProcessTableFunctionTestHarness.java | 2184 ++
.../table/runtime/functions/ResolvedMethod.java | 60 +
.../table/runtime/functions/RowStateConverter.java | 60 +
.../table/runtime/functions/StateConverter.java | 54 +-
.../functions/StructuredTypeStateConverter.java | 67 +
.../runtime/functions/TestHarnessCallContext.java | 109 +
.../functions/TestHarnessDataTypeFactory.java | 99 +
.../runtime/functions/TestHarnessStateManager.java | 236 +
.../functions/TestHarnessTableSemantics.java} | 58 +-
.../runtime/functions/TestHarnessTimerManager.java | 181 +
.../flink/table/runtime/functions/Timer.java | 135 +
.../ProcessTableFunctionTestHarnessTest.java | 2771 ++
.../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 | 50 +-
.../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 +
931 files changed, 59291 insertions(+), 39323 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/main/java/org/apache/flink/fs/s3native/BucketConfigProvider.java
create mode 100644
flink-filesystems/flink-s3-fs-native/src/main/java/org/apache/flink/fs/s3native/S3BucketConfig.java
create mode 100644
flink-filesystems/flink-s3-fs-native/src/test/java/org/apache/flink/fs/s3native/BucketConfigProviderTest.java
create mode 100644
flink-filesystems/flink-s3-fs-native/src/test/java/org/apache/flink/fs/s3native/S3BucketConfigTest.java
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-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.less
=>
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
copy
flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.less
=>
flink-table/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
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RegexpExtractInputTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RegexpInputTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RegexpReplaceInputTypeStrategy.java
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/catalog/DefaultCatalogTableTest.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
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/RegexpExtractInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/RegexpInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/RegexpReplaceInputTypeStrategyTest.java
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
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/materializedtable/SqlAlterMaterializedTableOptionsConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/materializedtable/SqlAlterMaterializedTableResetConverter.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/catalog/DescribeCatalogTest.java
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
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/CoalesceFunction.java
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/ProcessTableFunctionTestHarness.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/job/exceptions/job-exceptions.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/TestHarnessCallContext.java
create mode 100644
flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessDataTypeFactory.java
create mode 100644
flink-table/flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessStateManager.java
copy
flink-table/{flink-table-common/src/test/java/org/apache/flink/table/types/inference/utils/TableSemanticsMock.java
=>
flink-table-test-utils/src/main/java/org/apache/flink/table/runtime/functions/TestHarnessTableSemantics.java}
(56%)
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/ProcessTableFunctionTestHarnessTest.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
