Range select few commits

[tisonkun]

Is there an existing issue for this?

• [X] I have searched the existing issues

Description of the bug

I'm wondering how RANGE selection works because a release-1.17.0..release-1.18.0 selection on Flink give fewer result than expected.

Steps To Reproduce

gh repo clone apache/flink
cd flink
git cliff release-1.17.0..release-1.18.0
git log --oneline release-1.17.0..release-1.18.0

Expected behavior

The cliff output is:

 WARN  git_cliff > "cliff.toml" is not found, using the default configuration.
# Changelog

All notable changes to this project will be documented in this file.

## [release-1.18.0-rc3] - 2023-10-18

### 📚 Documentation

- *(metric)* Fix incroect backPressure metric name

<!-- generated by git-cliff -->

... while the log diff tells:

$ git --no-pager log --oneline release-1.17.0..release-1.18.0
a5548ccc21d (tag: release-1.18.0-rc3, tag: release-1.18.0) Commit for release 1.18.0
9b837727b6d [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan
70ee020dc01 [FLINK-33000][sql-gateway] ResultFetcherTest should utilize TestExecutorExtension instead of using a ThreadFactory
4f11dfb2a70 [FLINK-33000][sql-gateway] OperationManagerTest should utilize TestExecutorExtension instead of using a ThreadFactory
5fbf5d5aa19 [FLINK-33000][sql-gateway] SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory
36594137fa0 [hotfix][docs] Update KDA to MSF in vendor solutions docs
2c8207a11a1 [FLINK-33158] Cryptic exception when there is a StreamExecSort in JsonPlan
f4093fcfcaf [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4
deb07e99560 [FLINK-33119][table] The pojo result returned be procedure should be Row of fields in the pojo instead of whole pojo object (#23450)
78b0b7b5cb5 [FLINK-33050][docs] Add notice of data duplicates for RTAS in docs This closes #23448
11882e92553 [FLINK-33050][table] Atomicity is not supported prompting the user to disable
2aeb99804ba [FLINK-32974][client] Avoid creating a new temporary directory every time for RestClusterClient
7997cf152cc [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of tiered storage
59368aedad9 [hotfix][network] Flush writing buffers when closing HashSubpartitionBufferAccumulator of tiered storage
9c1318ca7fa [FLINK-15736][docs] Add Java compatibility page
6e13c60e2ac [FLINK-33071][metrics,checkpointing] Log a json dump of checkpoint statistics when checkpoint completes or fails
dea458d732c [hotfix][network] Fix the bug of triggering disk writing in Hybrid Shuffle
9c960536c4a [hotfix][network] Optimize the backlog calculation logic in Hybrid Shuffle
0501d036584 [FLINK-33088][network] Fix NullPointerException in RemoteTierConsumerAgent for tiered storage
206609e822a [FLINK-33086] Protect failure enrichment against unhandled exceptions
9e5659ea652 [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3
3dcdc7f2938 [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267)
73632fa7ba7 [FLINK-30025][doc] improve the option description with more precise content
8ad22b82476 [FLINK-33010][table] GREATEST/LEAST should work with other functions as input (#23393)
d100ab65367 [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer
ae647e2b489 [hotfix][network] Fix the close method for the tiered producer client
f2584a1df36 [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser (#23388)
f66679bfe5f [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error (#23338)
53981d81d37 [FLINK-32999][connectors/hbase] Remove HBase connector code from main repo (#23343)
7339a5359cb [FLINK-31889][docs] Add documentation for implementing/loading enrichers
97d116645e3 [FLINK-32796][docs] Extend catalog store documentation (#23294)
184cfcdb0ca [FLINK-32796][table] Try to create catalog store path if not exists (#23293)
7f99a274f99 [FLINK-32962][python] Remove pip version check on installing dependencies.
69dd59c59f1 [FLINK-32475][docs] Add doc for time travel (#23109) (#23346)
2437cf56878 [FLINK-28513] Fix Flink Table API CSV streaming sink throws
5a8d42345cd [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails
c4093b80643 [FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed (#23278)
534279ee388 [FLINK-32821][examples] Add integrated tests for streaming examples
e21e3629bcc [FLINK-32821][examples] Include flink-connector-datagen for streaming examples
eccae4bb563 [hotfix][flink-examples] Fix wrong filtering and remove Scala version suffix for state-machine example pom
32743e177e0 [hotfix][doc] Fix wrong documentation of INSERT OVERWRITE statement for Hive dialect
ade9b5f32cd [FLINK-32982][doc] Not to suggest to swap flink-table-planner lib for using Hive dialect This closes #23324
5ec31f12143 [FLINK-32994][runtime] Adds proper toString() implementations to the LeaderElectionDriver implementations to have human-readable versions of the driver in log messages
94ba97a13ab [FlINK-32865][table-planner] Make ExecutionOrderEnforcer support OFCG
83915d909dc [FlINK-32865][table-planner] Add ExecutionOrderEnforcer to exec plan and put it into BatchExecMultipleInput
6e4c2d105a1 [hotfix][network] Fix the notification of inaccurate data availability in Hybrid Shuffle
750311755b5 [FLINK-32751][streaming] Fixes bug where the enqueued requests are not properly cancelled
848183c6dcd [FLINK-32751][streaming] Refactors CollectSinkOperatorCoordinator to improve its testability
b4503b6ac08 [hotfix][JUnit5] Migrates CollectSinkOperatorCoordinatorTest to JUnit5 and Assertj
f00205eb762 [hotfix][test] Refactors test to remove version and offset server-side checks
8551a39ee46 [FLINK-32758][python] Limit fastavro != 1.8.0
1f7796ee50c [FLINK-32758][python] Remove PyFlink dependencies' upper bounds
4868da92497 [FLINK-32945][runtime] Fix NPE when task reached end-of-data but checkpoint failed
94277e18746 [FLINK-32907][Tests] Fix CheckpointAfterAllTasksFinishedITCase hangs on AZP
e9566267639 [FLINK-32824][table] Port CALCITE-1898 to fix the sql LIKE operator which must match '.' (period) literally
fa2ab5e3bfe  [FLINK-32831][table-planner] Add check to ensure all tests in RuntimeFilterITcase have applied runtime filter.
6938b928e01 [FLINK-32831][table-planner] Adjust default value of max build data size of runtime filter to cover more cases
e48a0262834 [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side
ac3f3cf4802 [hotfix][table-planner] Fix the wrong traitSet and inputs in runtime filter related exec node
1b250f7128a [FLINK-32869][e2e] Fix Kubernetes tests on aarch64
69cae5e260d [BP-1.18][FLINK-32760][Connectors/Hive] Reshade shaded parquet in flink-sql-connector-hive (#23288)
339eb195144 [FLINK-32523][test] Increase the tolerable checkpoint failure number to avoid aborting after job failing for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted(#23283)
0ed30728ffb [FLINK-32523][test] Guarantee all operators triggering decline checkpoint together for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted
c78f440533e [FLINK-32905][table-runtime] Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn
8715f0a1e8c [FLINK-32296][table] Support cast of collections with row element types
9cd04bd004f [FLINK-32827][table-runtime] Fix the operator fusion codegen may not take effect when enabling runtime filter
cfa4a9c3556 Update for 1.18.0
404a7804188 [FLINK-32668] fix up watchdog timeout error msg in common.sh
b5b1340f91d [FLINK-32751][runtime] Refactors CollectSinkOperatorCoordinator to enable case-specific logging
1c76850ec7a [hotfix][test] Migrates RestClientTest to JUnit5/AssertJ
ed4937cbc0e [hotfix] Fix the deadlock of DiskIOScheduler#sortScheduledReaders of Hybrid Shuffle
66121c8486c [hotfix] Fix the inaccurate backlog number of Hybrid Shuffle in legacy mode
819ba92994a [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle
9546f8243a2 [FLINK-32888] Handle hasNext() throwing EndOfDataDecoderException
329ee55e2e3 [FLINK-32888] Expose file comparison assertion
b93216f7855 [FLINK-32788][runtime] Support the handling of exception when slow task detector notify slow tasks
7299da4cf68 [FLINK-32880][flink-runtime]Fulfill redundant taskmanagers periodically in FineGrainedSlotManager (#23230)
4bce9c09ca4 [FLINK-32876][runtime] Prevent ExecutionTimeBasedSlowTaskDetector from identifying tasks in CREATED state as slow tasks.
c8cbb0e2dec [FLINK-32879][flink-runtime]Ignore slotmanager.max-total-resource.cpu/memory in standalone mode (#23231)
5628c709787 [FLINK-32653][docs] Add doc for catalog store (#23110)
eab68f31193 [FLINK-31268][metrics] Change not to initialize operator coordinator metric group lazily (#22048)
18b4759cc34 [Flink-32356][doc] Add doc for call statement This closes #23130
13cb456eb30 [Flink-32356][doc] Add doc for procedure
5bf5003f5c7 [FLINK-32834] Use descriptive output file names
6faf3680d4d [FLINK-32834] Force parallelism of 1
3e5eca702d2 [FLINK-32834] Forward actual Maven error code instead of 1
6663b398244 [FLINK-32834] Fail early if dependency plugin fails
ed31bca4c9e [FLINK-32834] Add usage information and -h option to low-level scripts
b38cd662bcf [FLINK-32834] Add documentation to the scripts
109c7ff261b [FLINK-32834] Forward any additional args to maven
d3059389aea [FLINK-32834] Decouple compile.sh from maven-utils.sh
003eae50c36 [FLINK-32834] Streamline CI_DIR detection
e638115336b [FLINK-32834] Decouple low-level scripts from maven-utlls
4bcbc7caed9 [FLINK-32834] Remove FLINK_ROOT parameter
78b5ddb11df [FLINK-32834] Rework parameter quoting
d08356a1afe [FLINK-32834] Write all tmp files to /tmp/
5f719e748a0 [FLINK-32834] Clean/overwrite pre-existing tmp files
5d163dd39d6 [FLINK-32834] Run all compile scripts from root directory
1d1fe536022 [hotfix][runtime] Remove the unnecessary private put method in FileSystemBlobStore to prevent the createBasePathIfNeeded is called repeatedly
56bbd1dd6f8 [hotfix][docs] Fix the PyFlink job submission command
b56ae7822f6 [FLINK-32882][SlotManager] Fix NPE when PendingTaskmanager clear pending allocations twice. (#23224)
2b14c3ae834 [docs] Add documentation for SQL Client URL support
079cd60510d [FLINK-32730][table-planner] Fix the bug of Scan reuse after projection pushdown without considering the dpp pattern
6b7d6d67808 [FLINK-32844][table-planner] Does not apply runtime filter and DPP on same key
b3557cfdc0a [FLINK-32771][SlotManager] Remove the invalid config option slotmanager.request-timeout
48063531de7 [hotfix][docs] Add missing style options for `sql-client.display.color-schema` in docs (#23205)
fc2b5d8f53a [FLINK-32820][flink-java] Revert the ParameterTool related changes from FLINK-32558
f68967a7c93 [FLINK-32660][table] Introduce external FS compatible FileCatalogStore implementation (#23063)
ac85945947e [FLINK-32809][yarn] Fix the bug that there is no check when yarn.ship-archives configures the directory (#23191)
0f841624a38 [FLINK-32709][network] Fix the bug of low memory utilization for Hybrid Shuffle
f2ca310f3d5 [hotfix][network] Fix the unreleased bug for the tiered disk io scheduler
5f9b886fe8c [hotfix][javadocs] Fix some typo in java doc and comments
3cd0bf0a670 [FLINK-32581][docs] Add docs for atomic CTAS and RTAS (#23116)
545d9c69d6a [FLINK-32823][doc] Update the adaptive scheduler fall back strategy doc for batch jobs
dbaab1056f1 [FLINK-32816][doc] Remove the local recovery limitation for adaptive scheduler
76554d186ad [FLINK-32747][table] Fix ddl operations for catalog which is loaded from CatalogStore (#23133)
6806f30fe23 [FLINK-32768][runtime] Change ExecutionSlotAllocator#allocateSlotsFor return type to allow the order of execution and assignments to be inconsistent
9231d62d25d [FLINK-25447][table-planner] Fix batch query cannot generate plan when inserting into multi sinks from a sorted view (#20822)
2eb88b4115f [FLINK-32287][docs] Add doc for truncate table statement (#23046)
5654eb798c7 [FLINK-32731][e2e] Backup the hive-metastore, hdfs namenode and mysql logs (#23155)
3be078179d0 [FLINK-32713][core] Cascade deprecation to non-private methods that reference SourceFunction
dfb9cb851dc [FLINK-32670][examples] Migrate examples with strict deprecation compiler checks to Source API
0234027c55c [FLINK-32670][core] Cascade deprecation to classes that implement SourceFunction
28d94e826e4 [hotfix] Fix rpc-akka module reference
fa61dd439ec [FLINK-32144][connector/filesystem][test] Create a new minicluser instead of using MiniClusterExtension in tests that would kill JM/TM
dcdca1e4603 [FLINK-32741]Remove DataSet related descriptions in doc
8c9b1767e08 [FLINK-32689][table] Improve validation of local time zone
6e138f1a483 [FLINK-32708][network] Fix the write logic in remote tier of hybrid shuffle
e69f410baf9 [FLINK-32759][doc] Remove the `cluster.declarative-resource-management.enabled` in doc
c7d3e360530 [hotfix][checkpointing] Fix outdated java doc in SharedStateRegistry after FLINK-29913
aa98c18d2ba [FLINK-32558][flink-java] Deprecate all DataSet API
34729c88914 [FLINK-32656][table] Deprecate ManagedTable related APIs
50622df1f01 [FLINK-29527][format] Make unknownFieldsIndices work for single ParquetReader (#21149)
8176a0eca8a [hotfix][doc] Fix typo in JobManagerOptions (#22992)
b78cd3f5363 [FLINK-30636] [docs]: Typo fix; 'to to' -> 'to'
93da795b3b3 [FLINK-32734][build] Adds .mvn/maven.config to .gitignore
5e3cad51805 [FLINK-32685][streaming] Do not touch the branch related to changelog writer if it is already available.
85f32d6bcb3 [hotfix][state-changelog] Don't trigger new materialization unless the previous one is confirmed/failed/cancelled
bde09516be2 [FLINK-29913][checkpointing] Remove de-duplication from SharedStateRegistry#registerReference()
4467ad05bb9 [refactor][test] Introduce DiscardRecordedStateObject to avoid using mocks for state handles
6dcb10abf31 [FLINK-29913][checkpointing] Use PhysicalStateHandleID as a key for shared state of IncrementalRemoteKeyedStateHandle
255d83087c6 [FLINK-32560][Scala] Deprecate all Scala API
74babdab7fd [FLINK-32662][test] Fixes JobMasterTest#testRetrievingCheckpointStats with the AdaptiveScheduler
99b98338266 [FLINK-32715][test] Make test wait for application to stop before shutting down the other services (#23104)
2a1ae11f67f [hotfix][test] Removes error handling
476d68814ab [FLINK-31168][test] Makes TestJvmProcess.destroy() wait for the process to actually go away
8db8119138b [FLINK-32559] Deprecate Queryable State
d012b8c981b [FLINK-32559] Do not generate config option docs for Deprecated / ExcludeFromDocumentation classes.
b18bde9bb44 [FLINK-32675][doc] Add document for the tiered storage of hybrid shuffle
7d07ec270cc [FLINK-32663][checkpoint] Fix the bug that checkpoint should not be triggered after all tasks have received end-of-data when checkpoint is disabled
7a5500e390a [FLINK-32676][doc] Add doc for catalog modification listener
fc3035b40fb [FLINK-28046][core] Mark SourceFunction interface as deprecated
c61cbd7977b [FLINK-32705][connectors/common] Watermark alignment upgraded from Experimental to PublicEvolving
796555ecd30 [FLINK-32705][connectors/common] Remove the beta for watermark alignment
d11cc32948b [FLINK-32681] Wait for RocksDBStateDownloader threads on failure to ensure proper cleanup.
9e6f8e8e127 [FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained with a MultipleInput node.
8386ef57ca5 Revert "[FLINK-32223][runtime][security] Add Hive delegation token support"
8ed28b45109 [FLINK-32686][network] Avoid creating tiered internal shuffle master before enabling the tiered storage
c6d58e17e8c [FLINK-32098][runtime] Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO
70e635983dc [FLINK-32223][runtime][security] Add Hive delegation token support
fd0d2db378d [FLINK-32519][docs] Add doc for [CREATE OR] REPLACE TABLE AS statement (#23060)
1f73784078d [hotfix][rest] Expose fields with getters for testing
c0576e5a907 [hotfix][rest] Improve RestClientTest test case
b2920728a20 [FLINK-32583][rest] Fix deadlock in RestClient
3f63e03e831 [FLINK-32691] Make it possible to use builtin functions without catalog/db set
c8a39797d36 [FLINK-32703][hotfix] Fix typo in shading com.google.protobuf:protobuf-java in flink-python
7b5fe279cde [hotfix] Revert accidentally committed change to `.idea/vcx.xml` as part of f6d09c5c0182767243d6628fb257ddd0a93482e4
ed99f5e37f1 [FLINK-32683][rpc] Update Pekko from 1.0.0 to 1.0.1
65f200b819e [FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink
3c452de8922 [FLINK-32460][doc] Add doc for show procedures statement (#23076)
49998998ca8 [FLINK_32628][python] Fix build_wheels_on_macos fails on AZP
c8ae39d4ac7 [FLINK-32468][rpc] Switch from Akka to Pekko
dc08df61329 [FLINK-32168] RM logs missing and current resources
e8a8b05b18f [FLINK-32655][runtime] Fix checkpoint aborted message being swallowed by RecreateOnResetOperatorCoordinator.
f0aec3a69fa [FLINK-32664][table] Fix TableSourceJsonPlanTest.testReuseSourceWithoutProjectionPushDown
9ef67388a02 [FLINK-32634][table-api] Deprecate StreamRecordTimestamp and ExistingField
6a3808213d3 [FLINK-32657][table-planner] Revert upgrading ExecNode versions for StateMetadata
7be5480212c [FLINK-32167] Log changes to TM resource budget
29a5e52dcd6 [FLINK-32167] Log resource profile for allocated slot
5cda33d87be [FLINK-32654][configuration] Deprecate ExecutionConfig#canEqual(obj)
eab99b6de82 [FLINK-32640][Network] Measure backpressure time for tiered storage hybrid shuffle.
51b0df65886 [FLINK-32640][Network] Measure backpressure time for legacy hybrid shuffle.
c8dfb2a1c68 [FLINK-32430][table] Support configuring CatalogStore using configuration
e3154d3e4c8 [FLINK-32429][table] Introduce CatalogStore in CatalogManager
65214293470 [FLINK-32431][table] Support configuring CatalogStore in Table API
f8812dc3bc8 [FLINK-32433][table] Add built-in FileCatalogStore implementation
48d4d5ccd8d [FLINK-31643][network] Restrict the max number of required buffers per input gate in tiered storage
afaa6c2f5aa [FLINK-31643][network] Restrict the min number of required buffers per result partition in tiered storage
c9e18336426 [FLINK-31643][network] Implement the TieredStorageConfiguration and enable TieredResultPartition
8f4409e717c [FLINK-32407][table] Notify catalog modification listener for table ddl in CatalogManager (#23041)
9f73d3d81a5 [FLINK-32492][table-planner] Add ITCase for runtime filter
72bee90ccb4 [FLINK-32492][table-planner] Introduce FlinkRuntimeFilterProgram
ad20b19fff8 [FLINK-32492][table-planner] Introduce ExecNode for runtime filter
8659dd788d0 [FLINK-32492][table-planner] Introduce configuration options for runtime filter.
a0a66d70398 [FLINK-32279][table-runtime] Add plan test for MulitpleInput support one-input node as root when operator fusion codegen enabled
bff837622dd [FLINK-32279][table-runtime] Shuffle HashJoin support spill to disk when enable operator fusion codegen
bc964a102a8 [FLINK-32632][test] Downloads binaries for cri-dockerd to avoid building the binaries using Go
17f1d2dde76 [hotfix][test] Introduces local variables for cri-dockerd version
d95a64ea5ef [hotfix][test] Makes wget calls less verbose
72bff2a2d00 [FLINK-31843][runtime] remove redundant SlotPool#getFreeSlotsInformation
3cdf228191a [FLINK-31843][runtime] Improve performance of SlotSelectionStrategy by bulk select.
a69f96514f3 [FLINK-31843][runtime] delete SlotInfoWithUtilization since it's unused.
f1a079f95e4 [FLINK-31843][runtime] SlotSelectionStrategy use FreeSlotInfoTracker to select the best slot.
3efbae44b4a [FLINK-31843][runtime] Introduce FreeSlotInfoTracker to manage available slots for SlotSelectionStrategy
7a9efbff0a2 [FLINK-32387][runtime] InputGateDeploymentDescriptor uses cache to avoid deserializing shuffle descriptors multiple times
4d642635c94 [FLINK-32386][runtime] Introduce ShuffleDescriptorsCache to cache ShuffleDescriptorGroup
fa4518960fd [FLINK-32385][runtime] Introduce ShuffleDescriptorGroup to identify a group of ShuffleDescriptorAndIndex
c0044be734a [FLINK-32608][table-planner] Support scan reusing with projection pushdown
c868d227308 [FLINK-31575][hive] Avoid swapping table-planner-loader and table-planner to use hive dialect (#22862)
17be3716be4 [FLINK-32646][table-planner] Fix TestTimeTravelCatalog missing snapshot version and add version info into source table's digest
6fd47ec7cbf [FLINK-32280][table-runtime] Fix the failed batch agg tests due to doens't mock the filterArgs
b74bf010c48 [FLINK-32280][table-runtime] Add ITCase for HashAgg operator fusion codegen
53649ef98ef [FLINK-32280][table-runtime] Extend MultipleInput algorithm to support one-input node as root node if operator fusion codegen enabled
f500b593911 [FLINK-32280][table-runtime] HashAgg support operator fusion codegen
59850a91f96 [FLINK-32491][table-runtime] Introduce RuntimeFilterCodeGenerator
151566d21e7 [FLINK-32406][table] Notify catalog modification listener for database ddl in CatalogManager (#23039)
410b52a35a1 [FLINK-32474][table] Support time travel in table planner (#22939)
41b35260bba [FLINK-32493][table-runtime] Introduce GlobalRuntimeFilterBuilderOperator
47596ea9250 [FLINK-32493][table-runtime] Introduce LocalRuntimeFilterBuilderOperator
7e2bc6e8d21 [FLINK-32354][table] Supports executing call procedure statement This closes #22994
78aa02f106c [FLINK-32354][table] Planner supports converting call procedure statement to CallOperation
b9c5dc3d731 [FLINK-32616][jdbc-driver] Close result for non-query in executeQuery (#23027)
a5a741876ab [FLINK-32617][jdbc-driver] Return true or false for most methods in database meta data (#23019)
05191071638 [FLINK-32456][table-planner] Support JSON_OBJECTAGG & JSON_ARRAYAGG use with other aggregate functions
d6967dd7301 [FLINK-32610][json] Add document for Json option decode.json-parser.enabled
c6cd5b68058 [FLINK-32610][json] Introduce JsonParserToRowDataConverter based JsonParserToRowDataConverter deserialization schema which supports projection push-down of nested fields
58f7ceb4501 [FLINK-32610][json] Introduce JsonParser based JsonParserToRowDataConverter with better performance
288a4982c34 [FLINK-32428][table] Introduce base interfaces for CatalogStore
acd34941e34 [FLINK-32169][ui] Show slot allocations on TM page
86207724d5b [FLINK-19010][metric] Introduce subtask level restore metric
fd96076b1b4 [FLINK-32404][table] Add catalog modification listener interface and create listener for catalog manager (#22924)
d8e77674a88 [FLINK-32403][table] Add database related operations in CatalogManager (#22869)
b332483792c [hotfix][streaming] Reactive sanity check for windowOperator's mergeable state.
7b9b4e53a59 [FLINK-32469][REST] Improve checkpoint REST APIs for programmatic access
e732edb41a4 [FLINK-32586][coordination] Enable input locality in SimpleExecutionSlotAllocator.
6b3d291f6a5 [FLINK-32623] Return correct vertex resource lower bound
13d35365f67 [FLINK-32592] Fix thread-safety of context (Stream)ExEnv initializer
3886f1f3963 [FLINK-32625][tests] MiniClusterTestEnvironment supports customized MiniClusterResourceConfiguration
99c652ce347 [FLINK-32624][network] Fix the TieredStorageConsumerClientTest
1635a284d75 Revert "[FLINK-28046][connectors] Mark SourceFunction interface as @deprecated"
698b128e20d [FLINK-32578][table-planner] Fix wrong plan which group by window time columns on a proctime window operator may result hang for ever
543091275f1 [hotfix][docs] fix typo in table api operations
1786e2ddfd1 [FLINK-32576][network] ProducerMergedPartitionFileIndex supports caching regions and spilling regions to file
0ef0dbd4077 [FLINK-32576][network] Extract file data index cache for hybrid shuffle
663a68f2c56 [FLINK-32613] Add ConfigOption for disabling TimestampInserter
cc9712bfe92 [FLINK-32518][table] Enable atomicity for [CREATE OR] REPLACE TABLE AS statement (#22995)
36b4531ab42 [FLINK-30984][table] Upgrade Janino to 3.1.10 and remove explicit cast required by 3.1.9
9c3c8afbd93 [FLINK-31647][network] Introduce the RemoteTierConsumerAgent
1bf06cfefad [FLINK-31647][network] Introduce the SegmentPartitionFileReader
55f4d863564 [hotfix][network] Remove unused helper and fix the TieredStorageConsumerClient
0f2ee60c277 [FLINK-32365][hive] Allow Hive source to scan table to get statistics in parallel (#22805)
aa21eac3a14 [FLINK-32584] Make it possible to unset default catalog and/or database
bcdbc51c439 [FLINK-24402][metric] Add a metric for back-pressure from the ChangelogStateBackend
5cacd1216b0 [FLINK-31819][doc] Added documentations for advanced watermark features in sql
2aa9af15b41 [FLINK-31540][flink-table-planner] support to set idle-timeout options with table options and 'OPTIONS' hint
8f64775e577 [FLINK-31539][flink-table-planner] supported watermark alignment in sql layer.
a3471eab759 [FLINK-31536][flink-table] support to set watermark emit strategy with table options and 'OPTIONS' hint
e8b118598c6 [FLINK-32569][table] Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface (#22977)
4690dc2956d [FLINK-32489][runtime] Migrate tests of BloomFilterTest to junit5
c2cba015f2c [FLINK-32489][runtime] Support serialize and merge BloomFilter for runtime filter
43f89761890 [FLINK-23484][benchmark] Supports HEAP_CHANGELOG and ROCKSDB_CHANGELOG
e5937344330 [FLINK-23484][benchmark] Move state benchmark to test-utils package
255ed35f228 [FLINK-26549][table][tests] Add tests for INSERT INTO with VALUES leads to wrong type inference with nested types
34f4f94828d [FLINK-32298][network] Fix the bug that totalWrittenBytes of BufferWritingResultPartition misses some data
e1c96562305 [FLINK-32298][network][refactor] Add data to PipelinedSubpartition through BufferWritingResultPartition
72a30e5d645 [FLINK-32298][refactor] Using the static const instead of magic code in ResultSubpartition
8829b5e60a7 [FLINK-28743][table-planner] Supports validating the determinism for StreamPhysicalMatchRecognize
e5324c085f6 [FLINK-32481][table] Support type inference for procedure (#22904)
d7a3b3847dc [FLINK-32585] Filter javax.xml.bind:jaxb-api false positive for Pulsar connector (#22989)
f37d41cf557 [FLINK-32157] Replaces LeaderConnectionInfo with LeaderInformation (#22988)
bc4c21e4704 (origin/1.16) [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are starting
f89be70c2b0 [FLINK-31035] add warn info to user when NoNodeException happend
f480b6d313f (dev/master) [FLINK-22734][table-runtime] Fix comments for HashJoin and Calc OperatorFusionCodeGen
f03c26a6f01 [FLINK-32278][table-runtime] Calc and HashJoin operator support operator fusion codegen
6040f480aae [FLINK-32278][table-runtime] Introduce the Calc and HashJoin operator spec to support operator fusion codegen
1f062a38f43 [FLINK-32277][table-runtime] Introduce the base FusionStreamOperator for OFCG
02be55ab780 [FLINK-32277][table-runtime] Introduce the basic operator fusion codegen framework
354a8852766 [FLINK-32420][connectors/common] Using the HeapPriorityQueue to improve the watermark aggregation performance when parallelism is high
224aa2e9ca2 [FLINK-32420][refactor] Add the AbstractHeapPriorityQueueElement
2dfff436c09 [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers
61d8fec84ad [hotfix][network] Fix the availability of tiered result partition
e6f77bea706 [FLINK-32349][table] Support atomicity for CREATE TABLE AS SELECT(CTAS) statement (#22839)
4cf2124d71a [FLINK-32466] Replace STRING with CHARACTER for functions that don't support binary strings
2a6e8aeb30f [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default
c942d0f61a0 [FLINK-29319][table] Upgrade Calcite from 1.31.0 to 1.32.0
773feebbb24 [FLINK-32556][runtime] Renames contenderID into componentId (#22967)
4f5b2fb5736 [FLINK-32376][connector] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID
b4faca57038 [FLINK-32457][doc][table] Update documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify the limitation
7ec1813f36e [FLINK-32457][table-planner] Add test cases of unsupported usage for JSON_OBJECTAGG & JSON_ARRAYAGG
9aecb0ccad9 [hotfix][streaming] Fix typo in DataStream.java and DataStream.scala.
9a4119f9842 [hotfix][runtime] Removes unused members and fixed typo
e65b12e2b53 [hotfix][tests] Adds proper multi-threading to the test case
d2e6b94b374 [FLINK-31837] Makes the driver instantiation being performed lazily as soon as the first contender is registered
e6e0f47bf3e [FLINK-32260][table] Add ARRAY_SLICE function
1aef1f13b99 [FLINK-32547][docs] Add missing doc for Timestamp support in ProtoBuf format
6e61b932a3e [FLINK-32035][sql-client] Support HTTPS endpoints in SQL Client gateway mode (#22810)
d88ef0e355b [FLINK-32502][runtime] Remove the AbstractLeaderElectionService (#22959)
ffe7b07c2f4 [hotfix][test] Removes unused ClusterComponent enum
174cf255a50 [FLINK-32381][runtime] Replaces FatalErrorHandler in LeaderElectionDriver with LeaderElectionDriver.Listener#onError interface method
af75268e5bd [hotfix][tests] Adds error handling to ZK-related DefaultLeaderElectionService tests
0e69a7b7d76 [FLINK-32496][connectors/common] Fix the bug that source cannot resume after enabling the watermark alignment and idleness
4f995ff3546 [FLINK-32496][connectors/common][refactor] Improve watermark alignment log for easier troubleshooting
73a0b875407 [FLINK-32541][network] Fix the buffer leaking when buffer accumulator is closed
e31ecb9596a [hotfix][runtime] Removes obsolete Precondition (the executorService is final and set within the constructor)
c5fc72361f1 [FLINK-31814][runtime] Enables Precondition that checks that the issuedLeaderSessionID is set on revoke processing
d3a9ccbca5c [hotfix][docs] Fix incorrect example of user-defined function. (#22948)
6074d7b1f4c [FLINK-32397][docs]Add doc for add/drop/show partition (#22927)
08ef36eb3d6 [FLINK-32517][table] Support to execute [CREATE OR] REPLACE TABLE AS statement (#22949)
1354d2fae3f [FLINK-32373][sql-client] Support passing headers with SQL Client gateway requests (#22816)
df2747f31f0 [FLINK-32419][runtime] Renames leader election related classes/fields/methods
716aa11ad51 [FLINK-32419][runtime] Deletes obsolete/unused leader election related classes
cc804944c75 [FLINK-32391][yarn][test] Extend log whitelist for expected Akka shutdown WARN exception
58a849bcc49 [FLINK-31996] Chaining operators with different max parallelism prevents rescaling
32044ddd358 [FLINK-31646][network] Implement the remote tier producer for the tiered storage
b9d21f1bb2a [FLINK-31646][network] Implement SegmentPartitionFile for the tiered storage
f789db3024b [hotfix][network] Simplify the fields in TieredInternalShuffleMaster
13d09004de4 [hotfix][network] Remove partition file writer and reader for TierFactory#createProducerAgent
1fc3b3746b6 [FLINK-32501][table-planner] Fix wrong plan of a proctime window aggregation generated due to incorrect cost evaluation
d946eaac160 [FLINK-30598][table-planner] Fix wrong code generated for WatermarkGenerator due to inconsistent source type info when deserialized from compiled plan
9b8a01cdffd Revert "[FLINK-32327][ci] Java 17 skips python tests"
0e44dccf694 [FLINK-32544][python] Fix test_java_sql_ddl to works in JDK17
08d0e6b2030 [hotfix][runtime] Adds shutdown logic for the watchExecutorService to the k8s HA services
a46cf265326 [hotfix][runtime] Reorganizes ZooKeeperUtils
e35a236eb24 [FLINK-32409][runtime] Removes MultipleComponentLeaderElectionService dependency
38f4d133a78 [FLINK-31476] AdaptiveScheduler respects minimum parallelism
e56e87ee225 [hotfix][test] Migrates EmbeddedLeaderServiceTest to JUnit5/AssertJ
5dbbc695ed9 [FLINK-32421][test] Fixes testConcurrentRevokeLeadershipAndShutdown to test the actual functionality consistently
5509c612e3b [FLINK-32362] [connectors/common] increase the robustness of announceCombinedWatermark to cover the case task failover
ec222eae3f6 [FLINK-32388][filesystem]Add the ability to pass parameters to CUSTOM PartitionCommitPolicy (#22831)
7f34df40c0d [FLINK-32536][python] Add java 17 add-opens/add-exports JVM arguments relates to DirectByteBuffer (#22955)
44e1397e2e7 [FLINK-32539][tests] Update violations as a result of FLINK-27415 changes
4bc408b9750 [FLINK-32459][connector] Force set the parallelism of SocketTableSource to 1
db4b5943066 [FLINK-31784][runtime] Adds multi-component support to DefaultLeaderElectionService
b60c1549dbf [hotfix][runtime] Adds JavaDoc and tests besides adding some additional utility methods
0c37b5e311c [hotfix][test] Makes DefaultLeaderElectionService being instantiated within the try context
0015fd3d0b7 [FLINK-27415][Connectors / FileSystem] Read empty csv file throws exception in FileSystem table connector (#20006)
37341a5aeff [FLINK-32359][tests] Accept mandatory args in constructor
940cb746b91 [FLINK-32327][python] Fix PyFlink Kafka support to support JDK17 (#22940)
412118a6e68 [FLINK-32526] Bump Apache Parquet from 1.12.3 to 1.13.1
c6f443c9288 [FLINK-28386][runtime] Trigger an immediate checkpoint after all sinks finished
41462f76c0c [FLINK-32355][table] Support to list procedures (#22888)
5ac5163a0f6 [FLINK-32370][tests] Ignore logged exceptions in JDBC driver e2e test
c4e55b588d1 [FLINK-31645][network] Introduce the DiskIOScheduler to DiskTierProducerAgent
c12469e0161 [FLINK-31645][network] Introduce the DiskIOScheduler
25eb0cef638 [FLINK-31645][network] Introduce the ProducerMergedPartitionFileReader
f3eb364ef15 [FLINK-32498][table] Fix the problem of array_max return type, it should be forced to be nullable.
76d2a8d0deb [FLINK-32516][table] Support to parse [CREATE OR ] REPLACE TABLE AS statement (#22934)
f6d09c5c018 [FLINK-32511][FileSystems] Upgrade GCS connector to 2.2.15. This closes #22930
4b61e4b79e3 [FLINK-32390][Runtime / Web Frontend] Bump engine.io and socket.io in /flink-runtime-web/web-dashboard. This closes #22513
b402108f9bc [FLINK-32506][connectors/common] Add the benchmark for watermark aggregation when enabling the watermark alignment
0be92626ea7 [FLINK-32473] Introduce base interfaces for time travel (#22928)
c090846e5d7 [FLINK-32310][table] Support enhanced show functions syntax (#22903)
a7bd6de71de [FLINK-32438][runtime] Merges AbstractZooKeeperHaServices with ZooKeeperMultipleComponentLeaderElectionHaServices
310d85950b8 [FLINK-32436][runtime] Removes obsolete LeaderContender#getDescription()
d126ff0a85a [hotfix] Adds contenderID to EmbeddedLeaderElection
b229ecd0d6d [FLINK-32370][tests] Ignore logged exceptions in JDBC driver e2e test
962e51f7718 [FLINK-32259]-table-Add-ARRAY_JOIN-function
aad2023b379 [hotfix] Add missing release note on binding to localhost by default since Flink 1.15
972e15348c4 [FLINK-30141][s3][filesystem] Increase retries on MinIO container startup
1824c251d07 [FLINK-32132][table-planner] Cast function CODEGEN does not work as expected when nullOnFailure enabled
8dfd811bea4 [FLINK-32479][tests] Wait until request was processed before revoking leadership
728e679d354 [FLINK-31783][runtime] Migrates DefaultLeaderElectionService from LeaderElectionDriver to MultipleComponentLeaderElectionDriver
4fe3560015c [FLINK-32201][runtime]Automatically determine if the shuffle descriptor needs to be offloaded by the blob server based on the number of ShuffleDescriptor edges.
29e452eedfd [FLINK-32201][runtime] Abstract shuffle descriptor serialize related logic to ShuffleDescriptorSerializer.
a68c047cfca [hotfix] migrate task deployment related tests to junit5 and assertj.
c1740861727 [FLINK-32505][network] Fixed compilation error in ProducerMergedPartitionFileWriter.
00e10cd034d [FLINK-31644][network] Implement the disk tier producer for the tiered storage
8b0afcfd439 [FLINK-31644][network] Implement ProducerMergePartitionFile for the tiered storage
a77aa6576a7 [FLINK-31644][network] Introduce the interface of partition file writer and reader for the tiered storage
07bf511a32b [FLINK-28046][connectors] Mark SourceFunction interface as @deprecated
1ef99736979 [FLINK-32410] Replace new LinkedHashMap<>(size) with CollectionUtil.newLinkedHashMapWithExpectedSize(size)
4c5bca08a7b [FLINK-32410] Replace new LinkedHashSet<>(size) with CollectionUtil.newLinkedHashSetWithExpectedSize(size)
4532e41e8b1 [FLINK-32410] Replace new HashSet<>(size) with CollectionUtil.newHashSetWithExpectedSize(size)
ab9445aca56 [FLINK-32410] Replace new HashMap<>(size) with CollectionUtil.newHashMapWithExpectedSize(size)
9d7b1663296 [FLINK-32495][connectors/common] Limit the CoordinatorExecutorThreadFactory to be a one-off
6453a48e70f [hotfix] Migrate StreamExecutionEnvironmentTest to Junit5 and AssertJ
24e479571fa [FLINK-32495][connectors/common] Fix the bug that the shared thread factory causes the source alignment unit test to fail
167d5640b24 [FLINK-32467][rpc] Move common RPC utils to rpc-core
82776bffe7d [FLINK-32257][table] Add built-in ARRAY_MAX function.
21eba4ca4cb [hotfix][sql-client] Skip commons-io since flink-sql-client depends on it
1c7ca7cb519 [hotfix][sql-client] Apply same relocation rules for flink-sql-parser as in flink-table-planner
ab6a81118b4 [FLINK-28744][table] Upgrade Calcite to 1.31.0
5ad86c2f01b Revert "[FLINK-32257]-table-Add-ARRAY_MAX-function"
318d7e4daa8 [FLINK-32257]-table-Add-ARRAY_MAX-function
210dc81612d [FLINK-32478][connectors/common] Fix the bug that the shared thread pool causes the source alignment unit test to fail (#22900)
3f485162a37 [FLINK-32426][table-runtime] Fix adaptive local hash can't work when auxGrouping exist (#22856)
dfe6bdad0b9 [FLINK-31234][k8s] Add an option to redirect stdout/stderr to files
d78d52b27af [FLINK-32032] Upgrade to flink-shaded 17.0. This closes #22546
c11fd82e0cc [FLINK-32351][table] Introduce base interfaces for call procedure (#22821)
ccb8e9f291d [FLINK-17398][connector/filesystem] Filesystem sources support flexible path reading (#22249)
300902016bd [FLINK-32234][sql-client] Add test for truncate table in sql-client This closes #22696
f8df2d608af [FLINK-32234][table] Support to execute truncate table operation in TableEnvironmentImpl
45ce1926274 [FLINK-32234][table] Convert SQLTruncateTable to TruncateTableOperation
7466df0c3c5 [FLINK-32283][network] Implement the SortBufferAccumulator for the tiered storage
d0f3ba6e604 [hotfix][network] Fix the close method order in TieredResultPartition
876b1ec262f [FLINK-32411][connector/common] Fix the bug about SourceCoordinator thread leaks (#22845)
74ae4b24683 [FLINK-32379][build] Skip archunit tests in java1X-target profiles
af25884103e [FLINK-24911][table] Enable line numbers in SQL Client
b528d9b81c0 [FLINK-30596][coordination] Fix duplicate jobs when submitting with the same jobId
e33875e4a25 [FLINK-32465][runtime][security] Fix KerberosLoginProvider.isLoginPossible accidental login with keytab
873a56361bf [FLINK-32191][netty] support set keepalive options to NettyClient.
e35f33f539b [FLINK-32447][table-planner] Fix missing table hints when they inside a view referenced by an external query
7b96d815c0d [FLINK-32414][connectors/common] Don't emitLatestWatermark when lastEmittedWatermark is UNINITIALIZED
ac3cc8b27d7 [hotfix] Migrate SourceOperatorAlignmentTest to AssertJ
3f5428ff109 [FLINK-28227][connectors] Migrate o.a.f.streaming.examples to the new Source API
c5acd8dd800 [FLINK-31983][yarn] Add yarn acls capability to flink containers
118ac2bf454 [FLINK-31957][docs][table] Add user story for configuring operator-level state TTL via compiled plan (#22837)
509c9f26ce6 [hotfix] [parquet] Print stacktrace when reporting statistics failed (#22878)
b2117bed393 [FLINK-32316] [connectors/common] Scheduling announceCombinedWatermark period task during SourceCoordinator::start not in construct function to avoid duplicated task be scheduled
0c787f522ed [FLINK-32441] Fix DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (#22879)
6ebd9f3a5c9 [FLINK-32389] Bump guava from 27.0.1-jre to 32.0.0-jre
149a5e34c1e [FLINNK-30859] Remove all Kafka connector code from main repo
602261648db [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager. (#22793)
b3d0e51bdf9 [FLINK-32265][runtime] Use system classloader in JM for jobs without extra jars
14480c8ce4f [FLINK-32413][runtime] Adds fallback error handler to DefaultLeaderElectionService
9b63099964b [FLINK-32392][ci] Invalidate Maven repo cache on Azure every year to reduce its disk usage
43f5d038fb2 [FLINK-31413][hive] Change scope of flink-table-planner dependency from provided to test in Hive connector This closes #22620
71c4358965c [FLINK-31413][hive] HiveParser allows to parse Flink's special commands
a5d52550c51 [FLINK-31413][hive] Copy HintPredicate,NodeTypeHintPredicate, LogicalDistribution,LogicalScriptTransform,ExpressionBuilder from table-planner to Hive connector
39d15999754 [FLINK-31413][hive] Remove usage org.apache.flink.table.planner.functions.* of in Hive connector
8eb590cf79b [FLINK-31413][hive] Hive connector shouldn't use OperationConverterUtils
9ae5359b94d [FLINK-31413][hive] Hive connector shouldn't use PlannerQueryOperation
4248d05da09 [FLINK-32370][runtime] Change log level to debug for AbstractHandler when job has not been initialized or is finished
ed36b2062dd [FLINK-31956][table] Extend COMPILE PLAN statement to read/write from/to Flink FileSystem This closes #22818
c83eb5cd5a6 [FLINK-31956][table-planner] Fix COMPILE PLAN statement fails to write to file when parent directories do not exist
65217c35e7c [FLINK-20887][table-planner] Fix incorrect aggregate project merge for LogicalWindowAggregate
a4dbd81a307 [FLINK-20887][table-planner] Fix the fail case due to incorrect nullability of structured type
9b3c5ef4a42 [FLINK-20887][table-planner] Step2: fix incorrect calc merge via releated rules
e3bd2c02852 [FLINK-20887][table-planner] Pre-step: disable project merge during sql2rel phase by default
c2ea1282f88 [hotfix] Remove local timeout for Hybrid and Tiered result partition test.
0a3a62e30cf [hotfix] Extract IgnoreShutdownRejectedExecutionHandler.
01560a154fb [FLINK-32071][FLIP-306] Implement the snapshot manager for merged checkpoint files in TM
274aa0debff [FLINK-31731] Add backwards compatible constructor for DebeziumAvroSerializationSchema
50952050057 [FLINK-32205][rest] Add the option "rest.url-prefix" to support connecting to the server through a proxy.
2ed858318f3 [FLINK-32345][state] Improve parallel download of RocksDB incremental state. (#22788)
c4c633e8439 [FLINK-30342][test] Migrates ZooKeeperLeaderElectionTest to MultipleComponentLeaderElectionDriver
effcec82070 [hotfix][runtime] Improves initial logging for ZK leader retrieval and election
ef9f43847e7 [hotfix][runtime] Adds helper method that can specify a parent path that is used for the ZooKeeperRetrievalDriver
5553ea78488 [FLINK-30343][runtime] Migrates KubernetesLeaderElectionAndRetrievalITCase to the MultipleComponentLeaderElectionDriver interface
513881b0caa [hotfix][runtime] Makes MultipleComponentLeaderElectionDriver extend AutoClosable instead of defining the close() method itself.
f1233a32546 [FLINK-27241][table] Support DROP PARTITIONS statement for partitioned table (#22720)
f1ca261e1e9 [FLINK-30344][test] Migrates KubernetesHighAvailabilityTestBase-related tests to the MultipleComponentLeaderElectionDriver interface
02629a8428f [hotfix][runtime] Removes unused driver
d7f2ec3414c [FLINK-27243][table] Support SHOW PARTITIONS statement for partitioned table (#22721)
a83dd938592 [FLINK-31642][network] Enable NettyConnectionReader to notify upstream required segment id
67dd69247b8 [FLINK-31642][network] Introduce the MemoryTierConsumerAgent to TieredStorageConsumerClient
598e1b9b94e [FLINK-31642][network] Implement the MemoryTierConsumerAgent
4006de97352 [FLINK-31549][jdbc-driver] Add jdbc driver docs
c4b8cafe912 [FLINK-24592][Table SQL/Client] FlinkSQL Client multiline parser improvements
6a410899e2c [FLINK-32180][runtime] Moves error handling from DefaultMultipleComponentLeaderElectionService into the MultipleComponentLeaderElectionDriver implementations (#22656)
8119411addd [FLINK-32370][streaming] Fix warn log in result fetcher when job is finished
b462d0ec4d1 [FLINK-32288][runtime] Improve the scheduling performance of AdaptiveBatchScheduler
7e42493b021 [hotfix] Enrich hybridPartitionDataConsumeConstraint when create AdaptiveBatchScheduler in scheduler benchmark utils.
4586bcbe662 [FLINK-27240][table] Support ADD PARTITION statement for partitioned table (#22711)
de0efcbe533 [FLINK-31782][runtime] Makes DefaultLeaderElectionService implement MultipleComponentLeaderElectionDriver.Listener (#22640)
1a3151b5b9f [FLINK-32233][sql] Introduce SupportsTruncate interface (#22692)
f69ed3454f2 [FLINK-32374][table-planner] Fix the issue that ExecNodeGraphInternalPlan#writeToFile should support TRUNCATE_EXISTING for overwriting (#22820)
ba47237a0a4 [FLINK-32271][build] Bump snappy-java to 1.1.10.1
6e22b94e708 [FLINK-31665] [table] Add ARRAY_CONCAT function (#22717)
1ca19805ad3 [hotfix][state/changelog] Fix the description of ChangelogCompatibilityITCase
fa94fb5a027 [FLINK-31721][core] Move JobStatusHook to flink-core module
7d4ee28e85a [FLINK-32008][protobuf] Ensure bulk persistence is not supported
f64563bc1a7 [FLINK-32136][python] Fix the issue that Pyflink gateway server launch fails when purelib != platlib
4624cc47bec [FLINK-32369][ci] Setup Java 17 cron build
d11266ee102 [FLINK-32327][ci] Java 17 skips python tests
2940c02c986 [FLINK-25002][build] Add java 17 add-opens/add-exports JVM arguments
e323a895712 [hotfix][build] Set -XX:+IgnoreUnrecognizedVMOptions in surefire VMs
1297e18a4f7 [hotfix][yarn] Set -XX:+IgnoreUnrecognizedVMOptions for task managers
1b6db829502 [hotfix][yarn][tests] Simplify string construction
89c15245531 [hotfix] Fix license indentation
ed854c0240c [FLINK-32368][test] Fixes wrong interface implementation in KubernetesTestFixture
201456c5501 [FLINK-32177][runtime] Refactors MultipleComponentLeaderElectionDriver.Listener.notifyAllKnownLeaderInformation signature (#22642)
d8547fafd99 [FLINK-32358][rpc] Add rpc system loading priority
83ebe45c895 [FLINK-25000][build] Java 17 uses Scala 2.12.15
62b792d58c4 [FLINK-31781][runtime] Introduces contender ID in LeaderElectionService interface
65c3ce43bfe [hotfix][state] Fix incorrect comments of channel input state redistribution.
52dfc295cc9 [hotfix][docs] Add collection functions to chinese doc
9bcebe7db3a [FLINK-32337][table] ARRAY_UNION's element getter should respect not only first arg's nullability
d2e4490ca11 [FLINK-32338][build] Add FailsOnJava17 annotation
6ee1912e949 [FLINK-32034][python] Fix GET_SITE_PACKAGES_SCRIPT for Python 3.10
fdfff096a3a [FLINK-32311][runtime] Fixes deadlock scenario when closing the service while processing a leader event
681c4b32f0a [hotfix][runtime] Shortens log message code
aa054f6dcf2 [hotfix][runtime] Fixes JavaDoc
a521f5a98a7 [FLINK-32343][jdbc-driver] Fix exception in jdbc driver for jdbc tools
c0dab74002b [FLINK-32290][dist] Enable -XX:+IgnoreUnrecognizedVMOptions
8bf30a1f3b4 [hotfix][yarn][tests] Simplify string construction
6df09d833ca [FLINK-32336][tests] PartitionITCase#ComparablePojo now public
089e9edcb6f [FLINK-31673][jdbc-driver] Add e2e test for jdbc driver
a745c146a35 [FLINK-32225][Runtime] Executions in same Job use a shared TaskDeploymentDescriptorFactory
55630de18ba [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices
968e864fe0b [hotfix][test] Adds final keyword to fields in Testing implementation
9cb4276c662 [hotfix][test] Remove timeouts from ResourceManagerTaskExecutorTest
a9e38d29811 [FLINK-31233][Rest] Return readable information when task manager stdout files not exist.
c418b57870a [hotfix] migrate some taskmanager rest handler tests to junit5 and remove Mockito usage.
45ba7ee87ca [FLINK-32326][state] Disable WAL in RocksDBWriteBatchWrapper by default. (#22771)
626d70d86d3 [FLINK-31916][python] Respect 'env.java.opts.all' (#22776)
c270a741526 [FLINK-24998] Update CI image
86681f0c36d [FLINK-31940] DataStreamCsvITCase#CityPojo serialized as POJO
2e371e4b67c [hotfix][tests] Use long -enableassertions
c5334bc222c [FLINK-32329][tests] Do not override env.java.opts.all
54e9eca28cf [FLINK-31641][network] Implement the memory tier producer for the tiered storage
b9f7a0e4fe3 [hotfix][network] Fix the class name of TieredStoreResultSubpartitionView
c31547945f5 [FLINK-32314][rpc] Ignore classloading errors after actorsystem shutdown
77f911ae657 [hotfix] Simplify ActorSystem construction
50f069ce5b1 [FLINK-31919][core] Only run closure cleaner if serialization fails
f83c6e0cc9d [FLINK-32297][tests] FlinkImageBuilder uses Temurin images
408e52f4ac8 [hotfix][rpc] Add clarifying comment
f145341bd60 [FLINK-32304] Reduce rpc-akka dependency footprint
5fe0a506d59 [FLINK-32328][build] Set surefire base argLine in general settings
4d22ad0cc3f [FLINK-32301][test] Set options instead of replacing entire config
e6c751dd041 [FLINK-32238][ci] Stable libssl download
05e7bc0006c [FLINK-26515][test] Add exception handling for RetryingExecutorTest#testDiscardOnTimeout
4a742c86a91 [FLINK-32302][hbase] Disable tests on Java 17
c35534e9b76 [hotfix][runtime] Adds private constructor to utility class Executors
df2b9f8d472 [FLINK-32204][runtime] Separates the DirectExecutorService from the DirectExecutor again.
ea26cdb8ccb [hotfix][runtime] Merges TreeCache creation into utility method
02ab5374e88 [FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout to 1 second (#22742)
fc63153031d [FLINK-32289][docs][kafka] Fix incorrect metadata column type in Kafka table connector examples
c7afa323582 [FLINK-32300][jdbc-driver] Support getObject for FlinkResultSet
a6adbdda0cd [FLINK-31835][table-planner] Fix the array type that can't be converted from the external primitive array
28abe81e5e4 [FLINK-31806] Fix public API rule for connectors and update the violations
022571478c0 [hotfix] Update archunit violations
025a95b627f [FLINK-27925][kubernetes]  adding the resourceVersion=0 when doing the list pods.
f2c49edc43f [FLINK-27925][kubernetes] refactor TestingWatchCallbackHandler for watch tm pod.
4e82ab0c37a [FLINK-31636][network] Introduce the TieredStoreResultSubpartitionView
a58c1980912 [FLINK-31636][network] Introduce the EndOfSegmentEvent
6398abcbff0 [FLINK-31636][network] Introduce the NettyService framework
d857cfda152 [FLINK-30585][flamegraph] Collect the flame graph of a single subtask instead of all subtasks when viewing the flame graph of a single subtask
446758769ce [FLINK-30585][flamegraph][refactor] Remove the unused generic inside of JobVertexThreadInfoTracker
c6c8109d102 [FLINK-30585][flamegraph][refactor] Optimize the naming related to the flame graph to distinguish between job vertex and execution vertex
37d686e4565 [FLINK-32236][yarn][tests] Ease allow-list regex
27285d67127 [FLINK-30480][runtime] Add benchmarks for adaptive batch scheduler.
dfa9e09d84e [hotfix] Migrate scheduler benchmark related tests under flink-runtime module to junit5.
31e17bd13ef [FLINK-31790][connectors/filesystem] Respect the PartitionCommitPolicy for batch Filesystem mode (#22387)
a86b89b4223 [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5
eacd5c1d90c [FLINK-32294][e2e] Fix HiveITCase failure (#22740)
191ec6ca394 [FLINK-30919][docs] Fix typo for the sink ability part in the document of User-defined Sources & Sinks
79b06cf9538 [FLINK-31677][table] Add built-in MAP_ENTRIES function. (#22312)
379e4910547 [FLINK-32232][table] Supports parse truncate table statement (#22691)
77214f138cf [FLINK-31774][doc] Add document for delete and update statement (#22398)
98f5500fea9 [FLINK-30660][sql-client] remove hive dependency in sql-client test This closes #22679
3f7e9245de5 [FLINK-30660][e2e] Add e2e test for hive
6b04e8c464e [FLINK-32267] Upgrade tesctcontainers from 1.17.6 to 1.18.3
a008f25b871 [FLINK-32254][runtime] FineGrainedSlotManager may not allocate enough taskmanagers if maxSlotNum is configured
9e12704a777 [hotfix] Migrate SlotManagerConfigurationTest to Junit5 and AssertJ.
83ba6b5348c [FLINK-32219][sql-client] Fix SqlClient hangs when executing EXECUTE PLAN statement (#22703)
bc2fee44a87 [FLINK-31812][api] Transform savepoint path to null if empty in body
43be40f5b5a [FLINK-28853][Docs] Sync watermark split alignment documentation with the Chinese version. This closes #22716
7403e2efea2 [FLINK-32250][configuration] Revert the field name of BUFFER_TIMEOUT
1b17259cdfd [hotfix] Migrate StreamExecutionEnvironmentTest to Junit5 and AssertJ
81cab8f4869 [FLINK-32213][core] Add get off heap buffer in segment
3046875c7aa [FLINK-32220][table-runtime] Improving the adaptive local hash agg code to avoid get value from RowData repeatedly
0a41a660600 [FLINK-32059] Update Jackson-BOM to 2.14.3
ebfeb3208cb address review comment
ffd34d42b6e address reveiw comment
54664cf6d17 [connector/hbase] Using strongly increasing nanosecond timestamp and DeleteColumn type to fix data accidental deletion and non deletion issues when sink hbase.
a62f2f0f6de [FLINK-32186][runtime-web] Support subtask stack auto-search when redirecting from subtask backpressure tab
69def87107a [FLINK-32053][table-planner] Introduce StateMetadata to ExecNode to support configure operator-level state TTL via CompiledPlan (#22593)
6663c8b29f6 [FLINK-30966][table-planner] Optimize type inference for Character type and fix result type casting in IfCallGen (#21927)
3245e0443b2 [FLINK-32217][runtime] Fix NPE in MetricStore#updateCurrentExecutionAttempts.
daf476f76bd [FLINK-31640][network] Write the accumulated buffers to the right storage tier
f3ea19203b8 [hotfix][network] Fix the writing subpartition id for tiered storage producer client
b232a7ebbe3 [FLINK-30751] Align PyFlink RocksDB predefined options documentation with its Java equivalent.
581936f340a [FLINK-30751] [docs] Remove references to disableDataSync in RocksDB documentation
d04405c0f6e [FLINK-25284] Add support of null during generation
bfe49b2973d [FLINK-32245][table-planner] Rename NonDeterministicTests to NonDeterministicTest and fix incorrect test initialization
28c20ad70c7 [FLINK-31894][runtime] ExceptionHistory and REST API failure label integration
f3ab9626bf1 [FLINK-32199][rest] Remove redundant metrics in TaskMetricStore after rescale down.
686bc00fd48 [FLINK-25162][hive] Fix Java 17 compile issue
3b9f7cf8ffc [FLINK-31974] Do not crash jobmanager on Kubernetes client errors
74572519768 [docs] Deduplicate mistakenly repeated words
d90a72da2fd [FLINK-32226][client] Cleanup jobgraph file on submission failure
cc552f970e2 [FLINK-32231][Build System] Update libssl to 5.13, which is needed for all E2E tests
603181da811 [FLINK-31993][runtime] Initialize and pass down FailureEnrichers
0c9403f8ad7 [FLINK-31892][runtime] Introduce AdaptiveScheduler global failure enrichment/labeling
81902e81c43 [FLINK-32211][sql-client] Supports row format in executor
9880ba5324d [FLINK-31637][network] Implement the HashBufferAccumulator for the tiered storage
0b8bba6117b [FLINK-31785][runtime] Moves LeaderElectionService.stop into LeaderElectionService.LeaderElection.close
c5808b04fdc [FLINK-31997] Upgrade to fabric8 6.6.2
d6c3d332340 [FLINK-32166][ui] Show unassigned TM resources
522ff833ad7 [FLINK-32023][API / DataStream] Add config execution.buffer-timeout.enabled to flush only when the output buffer is full.
678370b18e1 [FLINK-28853] Document the split level watermark alignment feature and fixup grammar from the configuration table
3b53f30d396 [FLINK-31776][runtime] Refactored LeaderElectionService introducing LeaderElection interface
a7d1eaf1d68 [hotfix][test] The LeaderElectionService reset is not necessary anymore after the changes of cc5d321d (FLINK-25432)
8dd578057ac [hotfix][test] Remove timeouts from ResourceManagerServiceImplTest
2c9dcd3adb7 [hotfix][test] Remove timeouts from ResourceManagerPartitionLifecycleTest
f6287fe1bc5 [hotfix][runtime] Removes obsolete @Nonnull annotation from LeaderElectionService.hasLeadership method signature
a4de89450e1 [FLINK-32174][docs] Update Cloudera related product under vendor solutions
6b6df3db466 [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table
1ef847b2c52 [FLINK-32043][sql-gateway] Fix Sql Gateway doesn't validate set statement (#22644)
d62ad9d24bd [hotfix] Use https://repo.maven.apache.org in maven-utils.sh
2f015eb899f [FLINK-32110][python]Fix the native memory leak when using time window in Pyflink thread mode.
366d01d0860 [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters
b783da3ead0 [FLINK-32161][test] Migrate and remove legacy WorkingDirectoryResource.
d853b7104c1 [FLINK-32161][test] Migrate and remove legacy RocksDBResource.
c3409dcd0f7 [FLINK-32161][test] Migrate and remove legacy BlobServerResource.
a48c0ba0ae5 [FLINK-32161][test] Migrate and remove legacy LogLevelRule.
ff49c65bc12 [FLINK-32161][test] Migrate and remove legacy MultipartUploadResource and NettyLeakDetectionResource.
d79f4c1d39c [FLINK-32161][test] Migrate and remove legacy ZookeeperResource.
d40d410f83a [hotfix] Auto injects TestLoggerExtension for flink-tests
b60973da69b [hotfix] Exclude META-INF/services/org.junit.jupiter.api.extension.Extension for flink-runtime as it still used by JUnit4 modules.
a828e2336b1 [hotfix][doc]Fix typo in analyze.md
ac6aedbf0f3 [FLINK-31967][table-runtime] Fix LAG function get NPE when the input type is not null
24701ca4edf [FLINK-32154][build] Setup checkstyle rules to forbid mockito/powermock
1ff5a8a9769 [FLINK-31893][runtime] Introduce AdaptiveBatchScheduler failure enrichment/labeling
7d529a5a167 [FLINK-31832][runtime] Add benchmarks for end to end restarting tasks
d8c64a80848 [FLINK-32153][build] Limit powermock to core/runtime
1cc81aa68ce [FLINK-31891][runtime] Introduce AdaptiveScheduler per-task failure enrichment/labeling
ae9e38ade27 [FLINK-32056][Python][Connector/Pulsar] Add missing APIs in flink-connector-pulsar v4.0.0
fadde2a378a [FLINK-32162] Only log error if an error occurred
9b0a30f6359 [hotfix][doc] Use the flink-connector-jdbc v3.1 branch docs
fbf7b91424e [FLINK-32056][Python][Connector/Pulsar] Upgrade flink-connector-pulsar used in flink-python to v4.0.0, which is compatible with Flink 1.17.x and upwards
c6d7747eaef [FLINK-31639][network] Introduce the memory manager for tiered storage
99add045846 [FLINK-32152][tests] Consolidate mocking library usage
291414f9cde [FLINK-32149][tests] Remove trivial mockito usages
119b8c584dc [FLINK-31786][runtime] Removes unused classes
d94818e5f23 [FLINK-32141][checkpointing] turn down a log level in the SharedStateRegistry
2805f027e6b [FLINK-31354][tests] Increased timeout for NettyClientServerSslTest to improve test stability
70ac66d567e [FLINK-32058][tests] Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5
b6a633278cf [FLINK-32058][tests] Set the field access to true to support Scala tests
3cbacbf26f0 [FLINK-32129][fs-connector] Use string array in PartitionCommitInfo
9dfde1cf8dd [hotfix][doc] mvn 3.8.6 is recommended or higher
10f38e85d8d [FLINK-31972][tests] Remove powermock whitebox usages
4576e4384ff [FLINK-31773][runtime] Splits up DefaultLeaderElectionService.start(LeaderContender)
dbd07d38839 [hotfix][tests] Replaces TestingZooKeeperServer with ZooKeeperExtension
5b637243f27 [FLINK-29618][yarn-tests] Remove Timeout annotation in YARN-related integration tests
abe0fbf433f [FLINK-31498][runtime] Only request redundant task manager when all pending slots registered.
54b67844e7c [hotfix] Migrate TaskExecutorManagerTest to Junit5 and Assertj
5a89d22c146 [FLINK-32131][python] Support specifying hadoop config directory for HiveCatalog
f32052a1230 Revert "[FLINK-32123][e2e] Fix E2E kafka download timeout"
06688f345f6 [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver
a9383fd4d51 [FLINK-31890][runtime] Introduce DefaultScheduler failure enrichment/labeling
ab5af14361f [FLINK-32112][docs] Fix the deprecated state backend sample config in Chinese document
6695d84dbb7 [FLINK-32001][table] Row-level update should support returning partial columns (#22525)
522fac5c1d0 [FLINK-29542][docs] Fix typos in unload.md
efba9a74146 [hotfix][docs] Remove duplicate sentence in docker deployment documentation
777ae5cb2aa [FLINK-31971][tests] Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest
8c3637b47f3 [FLINK-32123][e2e] Fix E2E kafka download timeout
2c252922723 [hotfix] Fix typos of comment
420b5e319e1 [FLINK-31548][jdbc-driver] Introduce FlinkDataSource for flink jdbc driver
4bd51ce122d [FLINK-32030][sql-client] Add URLs support for SQL Client gateway mode (#22556)
ce286c969a5 [FLINK-32060][test] Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5
a8c757081c6 [FLINK-32060][test] Introduce NoOpTestExtension to make subclass unaware of @TestTemplate
354c0f455b9 [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints. (#22584)
5ba3f2bdea6 [FLINK-32052][table-runtime] Introduce left and right state retention time to StreamingJoinOperator
1957ef5fabe [FLINK-31118][table] Add ARRAY_UNION function. (#22483)
062ab75c3ff [hotfix][python] Update the incomplete cloudpickle package
4415c5150ed [FLINK-31609][yarn][test] Extend log whitelist for expected AMRM heartbeat interrupt
7046e91bc0e [FLINK-32094][network] Avoid creating tiered internal shuffle master before enabling the tiered storage
4dc2a98ed43 [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml.
4cbaa6ffd1e [FLINK-31780] Allow users to disable 'Ensemble tracking' feature for Curator framework
cad7e60081b [hotfix][docs] Remove savepoint and checkpoint mount instructions.
7d9027dbb3a [FLINK-31638][network] Introduce the TieredStorageConsumerClient to SingleInputGate
9d75f2447c7 [FLINK-31638][network] Introduce the TieredStorageConsumerClient and TierConsumerAgent
886dda2938c [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down (#22488)
62b11e2e117 [FLINK-31950][table-planner] Introduce StateMetadata
f0d01903aaa [FLINK-28016][ci] Update CI to use Maven 3.8.6
4fa80bf27b5 [FLINK-28203][build] Add ShadeOptionalChecker
49dcdf0fc2a [FLINK-28203][build] Mark bundled dependencies as optional
edf5666224f [FLINK-28203][tests] Add e2e shade plugin id
975d23b0e4c [hotfix][hive] Mark mapreduce-client-core as provided
b7154f2347b [FLINK-31749][hotfix][doc] Fix HadoopInputFormat example code for DataStream
ab5f25f4db8 [FLINK-31749][hotfix][doc] Remove unavailable HadoopOutputFormat for DataStream
82fb74e23b1 [FLINK-27518][tests] Introduce the state migration tests framework and refactor existing tests.
00d4419b1f4 [hotfix][runtime][security] Change the log level to DEBUG in HBaseDelegationTokenProvider#getHBaseConfiguration
7f4e834babe [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5
2d873629b43 [FLINK-31934][rocksdb][tests] Remove mocking
49a5810f0ea [FLINK-31913][sql] SQL client respects env.java.opts.client
531076042d3 [FLINK-32014][doc][hotfix] Add Cassandra source documentation to website (#22569)
8ef5cc8c3f8 [FLINK-32048][tests] Migrate DecimalITCase to JUnit5 to resolve the unstable test issues
24685395ccf [FLINK-18808][streaming] Include side outputs in numRecordsOut metric
835beb04ee2 [FLINK-18808][streaming] Introduce OutputWithRecordsCountCheck.
d5276d7aa25 [FLINK-18808][streaming] Introduce helper builder class for StreamConfigChainer.
69aca3e064b [FLINK-29841] fix the typo in docs/content/docs/deployment/config.md
80a924309ce [FLINK-31635][network] Introduce tiered result partition
7aba50fe56a [FLINK-31635][network] Introduce the multiple storage clients for the tiered storage
bd11c4036ef [FLINK-31635][network] Introduce tiered storage resource and the resource registry
8a903fa0a30 [FLINK-31635][network] Introduce the interfaces in the tier for the tiered storage
14707742d24 [FLINK-31635][network] Introduce the tiered storage configuration
e70c03495d5 [FLINK-31635][network] Introduce the identifiers in the tiered storage
88b3432a284 [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException.
03b5a4c8ee5 [hotfix][test] Migrates FutureUtilsTest from JUnit4/Hamcrest to JUnit5/jAssert
35254cbdc9a [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level
345ddf859f5 [hotfix] Migrate checkpoint statistics related tests to JUnit5 and AssertJ
400530d30af [FLINK-31546][jdbc-driver] Close all statements when connection is closed
ed9ee279e50 [FLINK-30815][tests] Migrate BatchTestBase to junit5
7a423666d0f [FLINK-30815][tests] Migrate BatchAbstractTestBase to junit5
63443aec09e [FLINK-32027][runtime] Fix the potential concurrent reading bug of index file for SortMergeShuffle.
cd3d6efb493 [hotfix] Remove unnecessary public modifier for PartitionedFileWriteReadTest
7adbd032e7f [hotfix][refactor] Reuse existing method in SortMergeResultPartition
827c29354b0 [hotfix] Use the Pulsar 4.0 docs
bdb0233eb83 [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating when instance path too long
3df65910025 [FLINK-31448][runtime] use fine-grained slot manager as default
3379c2c085d [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.
f80d7a4428e [FLINK-31764][runtime] Introduce getNumberOfRequestedMemorySegments and rename the old one to a more appropriate name.
babefacdde5 [hotfix] Fix the link to a private field in other class.
026d7ccfe1d [FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known.
6009e811ecf [FLINK-32010][runtime] Leader election/retrieval drivers should properly extend AutoCloseable instead of having their own close method with the same signature.
075f359fdbb [FLINK-32010][kubernetes] Rename KubernetesUtils#checkConfigMaps to KubernetesUtils#getOnlyConfigMap to provide more clarity.
058b1f5045d [FLINK-32010][kubernetes] Remove an unused parameter from KubernetesLeaderRetrievalDriver.
2ff4e220945 [FLINK-31544][jdbc-driver] Introduce DatabaseMetaData for jdbc driver
b814c369256 [FLINK-31878][runtime] Adds event processing in a separate thread to DefaultLeaderElectionService
ed195cfedbb [hotfix][test] Adds generic testing implementations for LeaderContender and LeaderElectionDriver
1d208f13d89 [hotfix][test] Adds helper method to testingLeaderElectionDriver for specifying session ID
43688339721 [hotfix][test] Adds utility methods to OneShotLatch
43528be1b10 [FLINK-32000][webui] Expose max parallelism in the vertex detail drawer.
00b1d4cf880 [FLINK-31443][runtime] Maintain redundant task managers to speed up failover
8a2b2729b9f [FLINK-31443][runtime] Maintain pendingSlotAllocationRecords in PendingTaskManager
62d3a47a990 [FLINK-31443][runtime] let ResourceAllocationStrategy decide which pending/idle task managers should be release.
92f8666ec1d [FLINK-31443][runtime] Only check idle timeout when resource allocator is supported.
2cabb157a4f [hotfix] Keep all calculations and deriving in SlotManagerConfiguration#fromConfiguration
8d430f51d77 [FLINK-31995][tests] Adds shutdown check to DirectExecutorService
7cdbfce8d1b [FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective
246c17b8aeb [FLINK-31110][web] Show "User Configuration" preserving lines and whitespaces (#21954)
333e023196d [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode (#22478)
742685b76c7 [FLINK-30921][ci] Adds mirrors instead of relying on a single source for Ubuntu packages
f3598c50c0d [FLINK-31888] Introduce interfaces and utility classes related to enrichment/labelling of failures leading to job restart.'
1102fc62b8c [FLINK-31933][core][tests] Remove reflective access
7a1c2b5750d [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.
0997037598f [hotfix][API / DataStream] Make remaining tests methods package private.
3664609c762 [FLINK-31884][table-planner] Fix the issue that upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip
d1b1b9f8b4e [hotfix][docs] Fix link to Ververica Platform
ed7ca22efc6 [FLINK-31962][Build System] Update libssl to 5.12, which is needed for all E2E tests
146847e53f1 [FLINK-31911][sql][tests] Fix address address construction
a3368635e3d [FLINK-28786][python] Check if cython could be enabled in only one place
8be25d15501 [FLINK-31876][QS] Migrate flink-queryable-state-client tests to JUnit5
f476675d454 [FLINK-31409][hive] Hive dialect shouldn't use interfaces in table-planner to build LogicPlan This closes #22166
d3450fb6c85 [FLINK-31409][table] Introduce public interfaces for pluggable dialect
642484484b9 [FLINK-31409][table] Introduce flink-table-calcite-bridge module
63166226f65 [FLINK-31543][jdbc-driver] Introduce statement for flink jdbc driver
3acb76dcf45 [FLINK-31935] Register handlers for resource requirements endpoints in all deployment modes (session, application, per-job).
aa2110fdb23 [FLINK-31831][runtime][tests] Use random ports as rest bind port and jobmanager rpc port to avoid port binding failure
262140c2bce [hotfix][runtime][tests] Migrate assertions in TaskManagerDisconnectOnShutdownITCase to Junit5 Assertions
4d50f78cf99 [FLINK-31912][build] Upgrade bytebuddy to 1.14.4
918b873c0c0 [FLINK-31897][tests] Fix the unstable test ClientTest#testRequestUnavailableHost
caf5c10e2ca [FLINK-31897][tests] Migrate ClientTest to JUnit5
b462b9f2da8 [FLINK-31915][python] Pass java opts as array
fa053e3f1f3 [FLINK-31842][runtime] Calculate task executor's utilization only when used
91ba5d93947 [FLINK-31842][runtime] Maintain free slots per task executor to optimize slot selection.
baf74c03413 [FLINK-31842][runtime] remove redundant class SlotInfoAndResources.
25926d1f90d [hotfix][tests] Migrate SlotSelectionStrategy and SlotPool related tests to JUnit5
d9eea81f3d9 [FLINK-31881][docs] Fix incorrect Chinese documentation page of Flink official CEP. This closes #22452
ed42b094496 [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder
e21de2dbaeb [FLINK-31900][typo] Fix some typo in java doc, comments and assertion message
4ca3604a6af [FLINK-30729][state/changelog] Refactor checkState() to WARN of StateChangelogWriter to avoid confusing IllegalException
a27e6fab46c [FLINK-30174][Web Frontend] Bump engine.io from 6.2.0 to 6.2.1
c02fcfbf9f3 [FLINK-30478][core] Migrate sun.net.util.IPAddressUtil -> Guava InetAddresses
f9b3e0b7bc0 [FLINK-31593][tests] Adds 1.17 reference data for StatefulJobWBroadcastStateMigrationITCase (scala) based on release-1.17.0 (with FLINK-31765 (commit: a11a8b48b2090677f811f1d735f2a2f8ccaba54d) cherry-picked).
b696e4125b8 [FLINK-31593][tests] Adds 1.17 reference data for StatefulJobSavepointMigrationITCase (scala) based on release-1.17.0 (with FLINK-31765 (commit: a11a8b48b2090677f811f1d735f2a2f8ccaba54d) cherry-picked).
888d0489801 [FLINK-31593][tests] Adds 1.17 reference data for StatefulJobWBroadcastStateMigrationITCase (java) based on release-1.17.0 (with FLINK-31765 (commit: a11a8b48b2090677f811f1d735f2a2f8ccaba54d) cherry-picked).
86e8df4fe8a [FLINK-31593][tests] Adds 1.17 reference data for StatefulJobSnapshotMigrationITCase (java) based on release-1.17.0 (with FLINK-31765 (commit: a11a8b48b2090677f811f1d735f2a2f8ccaba54d) cherry-picked).
800984babaf [FLINK-31593][tests] Adds 1.17 reference data for TypeSerializerUpgradeTestBase-related tests based on release-1.17.0.
fca07c6484b [FLINK-31593][tests] Adds 1.17.0 reference data for FlinkKafkaProducerMigrationTest based on release-1.17.0
a6e2e56baa3 [FLINK-31593][tests] Adds 1.17.0 reference data for WindowOperatorMigrationTest based on release-1.17.0
74e7a53a3cf [hotfix][tests] Removes unused base version files.
601df8e728d [FLINK-31593][tests] Adds 1.17.0 reference data for ContinuousFileProcessingMigrationTest based on release-1.17.0
4f8bb1843f2 [FLINK-31593][tests] Adds 1.17.0 reference data for FlinkKafkaConsumerBaseMigrationTest based on release-1.17.0
2d8cba222cc [FLINK-31593][tests] Adds 1.17.0 reference data for CEPMigrationTest based on release-1.17.0
e60fb06aa15 [FLINK-31593][tests] Adds 1.17.0 reference data for AbstractOperatorRestoreTestBase-related tests based on release-1.17.0
f5f69af1ced [FLINK-31799][docs] Introduce py_connector_download_link shortcode for externalized connectors.
cdd55109be7 [hotfix][docs] Make the Chinese description in py_download_link.html more conventional
5c4db55d306 [FLINK-31131][doc] Fix the missed INITIALIZING of ExecutionState in the state_machine doc
26bd5fe390e [FLINK-31752] Fix SourceOperator numRecordsOut duplicate bug
d46d8d0f6b5 [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment
0104427dc9e [FLINK-31878][connectors] Fix the wrong name of PauseOrResumeSplitsTask#toString
52bf14b0ba9 [FLINK-31723] Fix DispatcherTest#testCancellationDuringInitialization to not make assumptions about an underlying scheduler implementation.
378d3ca0d4b [FLINK-31723] Refactor DispatcherTest#testCancellationDuringInitialization to use Assertj matchers and to make it more explicit  what it actually tests.
c2ab806a362 [FLINK-31803] Harden UpdateJobResourceRequirementsRecoveryITCase.
f240a5110a0 [FLINK-31868] Fix DefaultInputSplitAssigner javadoc for class
e8bc564c3e8 [FLINK-24909][Table SQL/Client] Add syntax highlighting (#22063)
a1daa989e96 [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow when the source is idle
d2e4b74e4a2 [FLINK-31804] Allow MiniClusterTestEnvironment
d9e9d1ca741 [FLINK-31708][API/Type Serialization System] Make DataInputView#read(byte[], int, int) return 0 if len is 0.
bc859f6ffa9 [FLINK-31853][runtime] Remove use of ExecutionAttemptMappingProvider
c20910ad991 [hotfix][test] Migrate FailoverStrategyCheckpointCoordinatorTest to Junit5 and AssertJ.
e107783d91f [FLINK-31859][build] Update cyclonedx-maven-plugin from 2.7.3 to 2.7.7
839b3b9005c [FLINK-31839][filesystems] Fix flink-s3-fs-hadoop and flink-s3-fs-presto plugin collision
15c4d88eb78 [FLINK-31834][Azure] Free up disk space before caching
921267bcd06 [FLINK-31398][sql-gateway] Don't wrap context classloader for OperationExecutor when executing statement. (#22294)
c21979833f5 docs(metric): fix incroect backPressure metric name
e61fedda4de [hotfix][docs] Using `kubernetes` instead of `KubernetesHaServicesFactory` as high-availability.type for kubernetes_ha doc.
8308d82ff96 [hotfix][docs] Fix broken links caused by FLINK-29372.
423cdcb99c3 [FLINK-27998][table] Upgrade Calcite from 1.29.0 to 1.30.0
57f8d58614f [hotfix] replace deprecated calcite apis
0412329dea4 [FLINK-29214][Table API/SQL] Remove usages of deprecated Aggregate#indicator
1d9f12a9b40 [FLINK-31823] Make #testWebRescaleFeatureFlagWithReactiveMode work for the AdaptiveScheduler smoke test.
fc7d821dfa1 [FLINK-31787][docs] Add explicit ROW constructor to sql functions doc
9538fdaab29 [FLINK-31741][jdbc-driver] Support data converter for value in statement result
fe8ff46123e [FLINK-31818][docs] Fix incorrect description of security.kerberos.access.hadoopFileSystems in SecurityOptions
ffc6f3bfabd [FLINK-31763][runtime] Convert requested buffers to overdraft buffers when pool size is decreased
a3c38c1034d [hotfix][annotations] Fix the version enum for v1.18
43bd5e5efa2 [FLINK-31779][docs] Track stable branch of externalized connector instead of specific release tag
97dee4bd2ad [FLINK-31808][docs] Fix wrong examples of how to set operator name in documents
a6f0165c09b [FLINK-30852][runtime] Checking task cancelation explicitly rather than failing the cancel method
40d2cfbc11f [FLINK-31471] Allow setting JobResourceRequirements through WEB UI.
a81ffa6d019 [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout
3f70900fadb [FLINK-31792][WebUI] Fix resolution errors during NzNotificationService injection.
d3e835def1d [hotfix] [docs] Fix `ROW()` decleration syntax (#22302)
2dc37f06bd3 [FLINK-29334][runtime] Remove releaseAndTryRemoveAll in StateHandleStore
36145d4e3f0 [FLINK-31768][runtime] Removes contender description
a9bc791abdf [FLINK-31628][runtime] Check the heap index to avoid the same channel status being added/removed repeatedly.
fc31869e585 [FLINK-31628][runtime] Migrate related tests to Junit5
a11a8b48b20 [FLINK-31765][runtime][test] Disable changelog backend in migration tests with RocksDB backend
0191cf7d006 [FLINK-31767][table-planner] Improve the implementation for "analyze table" execution on partitioned table
3e4f653ffa0 [FLINK-30765][runtime] Hardens the contract of LeaderElectionService.stop
e03a60a3881 [hotfix][runtime] Refactors logging code in DefaultLeaderElectionService.
76d7e1ba8b3 [hotfix][doc] Fix the incorrect description for TO_TIMESTAMP function
0c6e51ffe3d [FLINK-31761] Fix Some Typo And Improve lambda expressions.
91e405dd285 [FLINK-31758][doc] Handles $full_version for sql_url in document.
ee912b55f94 [FLINK-31744] Subsume JobMasterGateway#getMaxParallelismPerVertex
be05eaff396 [FLINK-31744] Include JobVertex info in sparse EG
c132a2fba20 [hotfix] Fix typo
a5372e0c92c [FLINK-31170][Docs] The spelling error of the document word causes sql to fail to execute. This closes #22204
4f15da77dcb [FLINK-31738] Prevent name clash in generated clients
0c4db2dd577 [FLINK-31510][yarn] Replace deprecated getMemory by getMemorySize
65710b43731 [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs into Flink docs
69131d29497 [FLINK-31447][runtime] Add some unit tests for FineGrainedSlotManager.
86d7d6e2950 [FLINK-31447][runtime] Let ResourceManagerTest run with DeclarativeSlotManager and FineGrainedSlotManager
ddc61595bd1 [hotfix] Migrate some fine-grained slot manager tests to Junit5 and Assertj
8ee66535879 [FLINK-31735][docs] Document 'plan' field as object
6e95bfafa79 [FLINK-30844][runtime] Increased TASK_CANCELLATION_TIMEOUT for testInterruptibleSharedLockInInvokeAndCancel
97a4cc88eee [FLINK-31733][docs] Detect OpenAPI model name clashes
dcca520cb47 [FLINK-31733][tests] Simplify DocumentingRestEndpoint setup
76d1a4678c3 [FLINK-31733] Fix model name clashes
0415f7d1f9f [FLINK-31728][examples] Remove scala api dependency
887464f150b [FLINK-31704][Connectors/Pulsar] Pulsar docs should be pulled from dedicated branch
d60431b05ed [FLINK-31670][doc] Using v3.0.0-docs branch for es connector docs build.
d4e3b6646f3 [FLINK-31470] Add integration tests for Externalized Declarative Resource Management.
0a874de89cb [hotfix] Introduce InstantiationUtil#cloneUnchecked for the cases where we don't need to handle exceptions.
ccd0fe2d75a [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.
f8b0834fb83 [FLINK-31214][python] Add support for new command line option -py.pythonpath
a5ed2e76cb2 [hotfix][docs] Regenerate REST docs
a539eb2e84c [FLINK-31469] Allow setting JobResourceRequirements through REST API.
46aeebd150f [FLINK-31711][docs] Include complete-statement request body
7ee5780e77d [FLINK-31705][Build System] Remove Conjars as Maven mirror
8c44d58c4c4 [FLINK-31545][jdbc-driver] Create executor in flink connection
fb6caee1371 [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached.
cfe393dd870 [hotfix] Add missing @GuardedBy annotation for LocalBufferPool.
0a49f9d1e88 [hotfix] Some minor clean-up and typo fix for LocalBufferPool.
0542fae7e41 [hotfix][test] Migrate LocalBufferPoolTest to Junit5 and AssertJ.
7c6d8b0134c [FLINK-31707][python] Fix Pandas UDAF to support accepting constant string as inputs
ed0bbfb0c23 [hotfix][docs-zh] Fixed the inaccurancy in Chinese doc of ExecutionMode (#22326)
34a48cd7c46 [hotfix][Connectors/AWS][docs] Updating AWS docs branch to fix build
2f3b7016dcd [FLINK-31703][Connectors/AWS][docs] Update AWS connector docs to v4.1.0
ea9c9d97e6b [FLINK-29822] fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()
ab7b2b308ab [FLINK-31694][Web Frontend] Bump ua-parser-js in /flink-runtime-web/web-dashboard
77b1d8f7015 [FLINK-31693][Web Frontend] Bump http-cache-semantics in /flink-runtime-web/web-dashboard
1368542fd68 [hotfix][Connectors/MongoDB] Using v1.0.0-docs branch for docs build
7d29e1beb72 [FLINK-30950][connectors][aws] Remove flink-connector-aws-base since it has been migrated to flink-connector-aws
803a4c6454e [FLINK-31692][Connectors/MongoDB] Integrate MongoDB connector docs into Flink website
f3b63b7c962 [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in blob server
6c1ffe544e3 [FLINK-31690][python] Fix KeyedCoProcessFunction to set the current key into the context
6101ad313be [FLINK-31688][docs] Fix the broken links in docs for Azure Table Storage
9e83858c7dc [FLINK-31652][k8s] Handle the deleted event in case pod is deleted during the pending phase
9190ea96243 [FLINK-31305] fix error propagation bug in WriterCallback and use TestSinkInitContext general purpose sink testing tool
370929c838f [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs
7e16a0fa611 [FLINK-31672] Respect user-specified max parallelism
3072e176ad4 [FLINK-31468] Add mechanics to the Dispatcher for handling job resource requirements
d4464005416 [hotfix] Remove unused createdJobManagerRunnerLatch
122429f99b9 [FLINK-31621][table] Add built-in ARRAY_REVERSE function. (#22277)
e3f9df66e40 [FLINK-31631][FileSystems] Upgrade GCS connector to 2.2.11.
a1e4ba2a0ac [FLINK-31602][table] Add built-in ARRAY_POSITION function. (#22267)
b81291864e6 [FLINK-31547][jdbc-driver] Introduce FlinkResultSetMetaData for jdbc driver
cfb213040a0 [FLINK-31604][table] Reduce usage of CatalogTableImpl in table-planner (#22263)
e5b553a1206 [FLINK-31557][Metrics] Add separate executor for view updater
c2541cd1a56 [FLINK-28347][Test infrastructure] Update testcontainers dependency to v1.17.6
b1b762f0fa1 [FLINK-28347][Test infrastructure] Update jna to 5.8.0
4882fbd9744 [FLINK-31651][runtime] Improve logging of granting/revoking leadership in JobMasterServiceLeadershipRunner to INFO level
bb24ec9cd84 [FLINK-31657][rest][docs] Exclude isEmpty property
59462197ba7 [FLINK-31626][runtime] HsSubpartitionFileReaderImpl should recycle skipped read buffers.
0708b53488e [FLINK-31626][runtime] HsSubpartitionFileReader should not read buffers from disk after it has been released.
eeb446c0ed0 [FLINK-31165][table-planner] Improve the error message for order by clause
678789afb42 [FLINK-31590] Add mechanics to the JobMaster for handling job resource requirements
3814fe8ddf5 [FLINK-31522][jdbc-driver] Introduce FlinkResultSet for jdbc driver
0dd9bcb0a9c [FLINK-31399] AdaptiveScheduler should free excessive slots that are no longer needed after down scaling.
c6be7add044 [FLINK-31399] Add mechanics to the AdaptiveScheduler for handling job resource requirements
3d676a355e9 [FLINK-31399] Move desiredResources out of WaitingForResources
fc0ccf32552 [FLINK-31399] Add state hooks for reacting to new requirements
8986bf0f599 [FLINK-31399] Generalize ScaleUpController -> RescalingController
0f1536c8a6f [hotfix] Refactor JRR#findParallelism
a44fc5f7144 [hotfix][tests] Simplify config setup
bb2789b7527 [hotfix] Remove unused variable
b32d80e6da1 [hotfix][tests] Remove timeout
f14a02ecac3 [FLINK-31538][jdbc-driver] Support parsing catalog/database and properties for uri
de27786eba5 [FLINK-31541][ui] encode request params to support special characters in metrics name.
3924ba85e62 [FLINK-31612][Filesystems] Remove no longer necessary Hadoop relocation rules for Azure/GS/OSS filesystems
2a3652d8563 [FLINK-31598][table] Quotes the UUID table name to fix the failed tests
46a46195618 [FLINK-31598][table] Replace the usage of deprecated TableEnvironment#registerTable() with createTemporaryView()
d0f52112982 [hotfix][doc][table] Fix the incorrect syntax description for explain statement set
7f47c11da1b [FLINK-31305] Propagate producer exceptions outside of mailbox executor so that checkpoints can correctly fail
2e7f63948cf [FLINK-18996][table-runtime] Avoid disordering output records and watermark for time interval join
04dbdc0d0bd [hotfix][docs] Fix the example configuration of pipeline.cached-files. (#22273)
ca90244e84f [FLINK-31591] JobGraphWriter persists JobResourceRequirements
6620641db32 [FLINK-31554][docs-zh] Translate "Overview" page of "sql-gateway" into Chinese (#22235)
fc38c923f68 [FLINK-31556][docs-zh] Translate "rest" page of "sql-gateway" into Chinese (#22237)
f3c653ed2e4 [FLINK-31102][table] Add ARRAY_REMOVE function (#22144)
f6b55ca1396 [FLINK-31512][table-planner] Move SqlAlterView conversion logic to SqlAlterViewConverter This closes #22211.
c9150042315 [FLINK-31501][table-planner] Move SqlCreateView conversion logic to SqlCreateViewConverter
b8bc610b31a [FLINK-31568][tests] Updates base version for japicmp check.
60f3b2b32b5 [hotfix] Revert some unexpected changes of FLINK-31230. (#22260)
15fe1653ace [FLINK-31444][runtime]FineGrainedSlotManager reclaims slots when job is finished.
3d5a60402ae [FLINK-31441][runtime]FineGrainedSlotManager support evenly slot selection.
156d9a93dcc [hotfix] Migrate LeastUtilizationSlotMatchingStrategyTest/AnyMatchingSlotMatchingStrategyTest to Junit5 and Assertj
a5e05b713e2 [FLINK-31567][release] Add 1.17 to previous docs list (#22261)
c9de75052ea [FLINK-31555][docs-zh] Translate "hiveserver2" page of "sql-gateway" into Chinese
a64781b1ef8 [FLINK-31574][table-planner] Cleanup unused private methods in OperationConverterUtils (#22240)
027db900240 [FLINK-31452][table] Return sorted result for show databases (#22242)
a9fa484aa9b [FLINK-31567][release] Build 1.17 docs in GitHub Action and mark 1.17 as stable in docs (#22247)
1009196d1ff [FLINK-31149][docs] Update compatibility matrix for release 1.17 (#22244)
103e5f9fd0f [FLINK-31157][release] Add release note for version 1.17 (#22146)
753da61bb36 [FLINK-31230][yarn] Improve YarnClusterDescriptor memory unit display.
e91eb5ec2fe [FLINK-31466][table] Apply Calcite's optimization of pushing filter to semijoin for FilterJoinRule
9ba3b1a5863 [FLINK-31527][tests] Stabilize ChangelogRescalingITCase
18869f6dfd0 [FLINK-31513][doc] Fix incorrect path in tpcds-tool README (#22212)
824259ecf53 [FLINK-31424][table-planner] Fix NPE produced by multiple sink with local-global window aggregate
0c2db680f23 [FLINK-31516][table] Move execution logic of LoadModule and UnloadModule operations out from TableEnvironmentImpl
e342f127e7e [FLINK-31531][hive] Fix HiveCatalogHiveMetadataTest&HiveDialectITCase failure in Hive3 (#22230)
268fc1a46f8 [FLINK-30435][table] `SHOW CREATE TABLE` statement shows column comment
0303806fc18 [FLINK-31517][table] Move execution logic of AddJarOperation out from TableEnvironmentImpl
ef5b3173c15 [FLINK-30023][changelog] increase timeout in ChangelogStorageMetricsTest#testTotalAttemptsPerUpload for improving stability
fb37e6a87d9 [FLINK-31139][state/changelog] not upload empty state changelog file
4b10c7ccc40 [hotfix] Update copyright NOTICE year to 2023
47944ce00e0 [FLINK-31514][table-planner] Move query SqlNode conversion logic to SqlQueryConverter (#22213)
452986dd05b [FLINK-31507][table] Move execution logic of DescribeTableOperation out from TableEnvironmentImpl
96b17a63c51 [FLINK-31507][table] Move execution logic of ShowOperation out from TableEnvironmentImpl
25798e8b2ed [FLINK-31521][jdbc-driver] Initialize jdbc driver modules in flink-table
1d33773e6b7 [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records
d88f39c4486 [FLINK-31405][test] Refactor tests to git rid of timeout of CompletableFuture assertions.
dfba6cb91b4 [FLINK-31405][test] Introduce willNotCompleteWithin for FlinkCompletableFutureAssert.
f0ee3e68569 [hotfix] Remove public class & method modifier for some tests and migrate AdaptiveSchedulerTest to Juint5.
0180284381b  [FLINK-31487][table-planner] Add targetColumns to DynamicTableSink#Context
3d350485755 [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector (#21522)
1d97e443032 [FLINK-31506][table] Move execution logic of AlterOperation out from TableEnvironmentImpl (#22210)
3e6a831eb30 [FLINK-31504][table] Move execution logic of CreateOperation out from TableEnvironmentImpl (#22214)
a06aaa00b08 [FLINK-30700][docs-zh] Improve translate of the "Deduplication" page
f7ee479c08c [FLINK-30700][docs-zh] Translate "Deduplication" page of "Queries" into Chinese
4c8aa0ba7b0 [FLINK-30696][docs-zh] Improve translate of the "Join" page
abed76b106d [FLINK-30696][docs-zh] Translate "Join" page of "Queries" into Chinese
fa8230bd79d [FLINK-30714][docs-zh] Improve translate of "Window Aggregation" page
8c5f1ee214b [FLINK-30714][docs-zh] Translate "Window Aggregation" page of "Queries" into Chinese
dad718523fa [FLINK-30722][docs-zh] Improve translation of "Group Aggregation" page
8ea03789eda [FLINK-30722][docs-zh] Translate "Group Aggregation" page of "Queries" into Chinese
fb1f91d6731 [FLINK-30728][docs-zh] Improve translation of "Over Aggregation" page
b111bef6a47 [FLINK-30726][docs-zh] Translate "Over Aggregation" page of "Queries" into Chinese
5a468f582f6 [FLINK-30728][docs-zh] Improve translation of "Window Join" page
7c534f424df [FLINK-30728][docs-zh] Translate "Window Join" page of "Queries" into Chinese
9830fd831cf [FLINK-30731][docs-zh] Improve the translation of "Set Operations" page
aec9efb811b [FLINK-30731][docs-zh] Translate "Set Operations" page of "Queries" into Chinese
770d361048b [python][docs] Update PyFlink docker image build documentation
598f92f46f7 [FLINK-30735][docs-zh] Improve the translation of "Top-N" page
460227a7a89 [FLINK-30735][docs-zh] Translate "Top-N" page of "Queries" into Chinese
0a8bf944826 [python][examples] Add Python streaming word count examples
06be368a3f1 [FLINK-31505][table] Move execution logic of DropOperation out from TableEnvironmentImpl (#22209)
de258f3ce01 [FLINK-31503][python] Makes sure it loads Beam classes using the same class loader as the PyFlink classes
ba03d4db7ca [FLINK-31494][table-planner] Introduce SqlNodeConverter for SqlToOperationConverter
fa0dd3559e9 [hotfix][table] Rename SqlToOperationConverter to SqlNodeToOperationConversion
5e059efee86 [FLINK-31478][python] Fix ds.execute_and_collect to support nested tuple
ff08c7b1d7f [FLINK-31489][sql-gateway][tests] Fix instable test OperationManagerTest.testCloseOperation
4dd762b1090 [hotfix] Sort NOTICE dependencies in alphabetical order
a7605b0f5b0 [FLINK-31485][Confluent Avro] Change packaging of Schema Registry so that by default everything is included.
768c09c5183 [FLINK-31450][table] Move execution logic of UseOperations out from TableEnvironmentImpl
d95f69bb459 [FLINK-31450][table] Introduce ExecutableOperation for operations to execute
6f9bca971f6 [FLINK-31321][Deployment/YARN] Yarn-session mode, securityConfiguration supports dynamic configuration
81f77a9d0e7 [FLINK-30896][table] Reduce usage of CatalogViewImpl in table-planner
e42d7089b24 [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRAYS
db3a0a59519 [FLINK-31480][yarn] Fix typo in YarnClusterDescriptor.
a84de2ca4a9 [FLINK-31317] Introduce JobResourceRequirements and JobVertexResourceRequirements data structures.
f3955cff984 [hotfix] Mark InstantiationUtil#readObjectFromConfig as @Nullable.
cf33d934366 [hotfix][docs][docs-zh] Use markdown SQL template for SQL functions examples
f3ec5733f4f [FLINK-30959][hotfix][docs] Improve the example style of UNIX_TIMESTAMP function
99b5041a983 [FLINK-30959][table][docs] Improve the documentation of UNIX_TIMESTAMP function for different argument formats
7fccd5992f6 [FLINK-31420][test] Fix unstable test ThreadInfoRequestCoordinatorTest#testShutDown.
c3f9142303a [hotfix] Let ThreadInfoRequestCoordinatorTest more comply with the specifications of Junit and AssertJ.
e818c11d104 [FLINK-31085][formats] Add schema option to confluent registry avro formats
8990822bd77 [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results
cbfeef64e9b [FLINK-31414][checkpointing] make BarrierAlignmentUtil.DelayableTimer not hidden exception
0848815d41a [FLINK-31437][hbase][docs] Fix wrong key 'lookup.cache.caching-missing-key' in 'hbase.md'
617fcaa6074 [hotfix][table] Fix plan tests for the new PushCalcPastChangelogNormalizeRule
1b262d5a85d [FLINK-30129][table] Rename PushFilterPastChangelogNormalizeRule to PushCalcPastChangelogNormalizeRule
3f53ef1fad8 [FLINK-30129][table] Push projection through ChangelogNormalize
17b805bc9af [FLINK-30802][connectors] Document that SplitReader#fetch() may interrupt&resume
f949fe4eb1b [FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout
6149d156a23 [FLINK-31208][Connectors / Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)
63f5555d315 [FLINK-30748][docs] Improve the translation of Queries Overview page
5d15191bbd9 [FLINK-30748][docs] Translate "Overview" page of "Queries" into Chinese
a94b556e6a0 [FLINK-30694][docs] Improve the translation of "Windowing TVF" page
471b6ce8cba [FLINK-30694][docs] Fix REF_NOT_FOUND build error for docs
7b03113461c [FLINK-30694][docs]Translate "Windowing TVF" page of "Queries" into Chinese
20dc237f1b6 [FLINK-31369][sql-gateway] Harden modifiers in tests for sql-gateway module
a8848f8d6aa [FLINK-31227][docs] Remove Scala suffix for ORC and Parquet format download links on the the FileSystem documentation. This closes #22039
2bb10e5ef0c [FLINK-30747][docs] Improve the translation of "Window Deduplication" page
c5b68ebef4d [FLINK-30747][docs] Translate "Window Deduplication" page of "Queries" into Chinese
65ab8e820a3 [FLINK-30744][docs] Improve the translation of "Window Top-N" page
369e3b9feac [FLINK-30744][docs-zh] Translate "Window Top-N" page of "Queries"
231df6276f1 [FLINK-31378][doc] Fix dev/configuration overview.md
270e6fc2094 [hotfix][table] Printing column names in a deterministic order
d4a9a749310 [FLINK-25347][table] Replace deprecated TableSchema with Schema in MergeTableLikeUtil
981ef8bd874 [FLINK-30659][hive] Drop flink-sql-parser-hive module (#22106)
eb83d854629 [FLINK-31401][streaming][tests] Make parallelism assumption explicit in StreamingJobGraphGeneratorTest
a43a63c165c [FLINK-31404][table-planner] Support extracting all mapping of Calc node's input references for StreamNonDeterminisiticUpdatePlanVsitior
b63c65a10bc [FLINK-31393][runtime] Fix the bug that HsFileDataManager use an incorrect default timeout.
e22d164ff71 [FLINK-29743][table] CatalogPropertiesUtil supports de/serializing column comment (#22131)
a7b0c270751 [FLINK-31402][yarn] Remove usage of deprecated ConverterUtils method.
624c196f1cc [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle
8424ed2c02e [FLINK-31385] Introduce extended Assertj matchers for completable futures, that don't rely on timeouts.
49929f84497 [FLINK-31396][network] Replace the nano time by milliseconds as the timeout time for batch read buffer pool
0b497c56dbd [FLINK-31387][streaming-java] Harden StreamTaskCancellationTest#testCancelTaskShouldPreventAdditionalProcessingTimeTimersFromBeingFired by waiting for the first timer to be fired.
6d79f6fc52b [FLINK-31144][coordination] Ignore the input locations of a ConsumePartitionGroup if it has too many consumers
84d000cf47b [FLINK-31383] Add support for documenting additionProperties of the REST API payloads.
3577edf57f5 [hotfix] Apply spotless for AbstractHaServicesTest
10dce7cf0a0 [FLINK-31166][table] array_contains does not support null argument when the array element type is not null
5fef51f6008 [FLINK-31300][table] TRY_CAST for constructed types
593cc139ab3 Revert "[FLINK-30513][runtime] Cleanup HA storage path on cluster termination"
03e4f8eb13d [FLINK-31370] Prevent more timers from being fired if the StreamTask has been canceled.
13779ab8e4f [FLINK-30513][runtime] Cleanup HA storage path on cluster termination
eb66e6d18ec [hotfix] Migrate AbstractHaServicesTest to JUnit 5 and AssertJ.
384d6b10a2d [FLINK-31351][sql-gateway] Don't stop the stuck thread by force
d04d727958b [FLINK-30113] Implement state compression for broadcast and regular operator states (#21636)
75d94108a8e [FLINK-31279][table] Fix MULTIPLY(TIMES) function doesn't support interval types
ed30a4f906f [FLINK-30289] Make the backpressure tab could be sort by busy/backpressure/idle seperately
7c5b7be5bc1 [FLINK-31298] fix ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows IllegalArgumentException
56386c3bca3 [hotfix][docs] Fix the wrong configuration key of table.exec.simplify-operator-name-enabled in documentation (#22104)
eff9b16799f [FLINK-31360][test] Using an executor service which ignore rejectException as shutdown for HsResultPartitionTest.
3ea83baad0c [FLINK-31348][Docs] Fix unclosed shortcodes (/tabs) in the docs, that causes issues with Hugo version 0.111.0 and higher. This closes #22113
5ad2ae2c24a [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0.
faf663a6298 [hotfix][runtime] IO Scheduler should handle un-expected exceptions.
a3068310ba9 [hotfix][test] Remove meaningless reader in SortMergeResultPartitionReadSchedulerTest#testRequestTimeoutIsRefreshedAndSuccess.
babb82553c8 [FLINK-31347] Prevent AdaptiveSchedulerClusterITCase.testAutomaticScaleUp timing out.
6ac40847d3b [FLINK-31283][docs] Update the scala-2.11 related building doc
4fd3cf133a2 [FLINK-31337][python] Fix python keyed broadcast batch operator input not sorted
a2d78e60a96 [FLINK-30922][table-planner] Fix errors when reference metadata columns in column list of a partial-insert statement
bec6a458970 [FLINK-31297][Runtime] Use processResourceRequirements to allocate task manager in FineGrainedSlotManagerTest.
86e0a0b3842 [FLINK-31182][table] Fix CompiledPlan containing UNNEST
f47b3704867 [FLINK-31092][table-common] Fix ServiceLoaderUtil keeps loading even though the classloader has been closed
d2296422933 [FLINK-31092][sql-gateway] Fix OperationManager can not kill the running task by force
d5a66063b29 [FLINK-31324][connector] Reintroduce previous SingleThreadFetcherManager constructor and mark it as deprecated
84f532e6549 [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL
5ee7dcd97fc [FLINK-30983][runtime] Migrate SSLUtilsTest to junit5
88d28a17459 [FLINK-30501][doc] Update Flink build instruction to deprecate Java 8 instead of requiring Java 11
f1e746ee0a6 [hotfix][docs] Replace `serailize` with `serialize` in data_types.md
7f5240c9f91 [FLINK-31284][tests] Increase KerberosLoginProvider test coverage
62a3b99d232 [FLINK-31239][hive] Add some notes in document about table.exec.hive.native-agg-function.enabled option can't turned on per job when using it via SqlClient
263555c9adc [FLINK-31239][hive] Fix native sum function can't get the corrected value when the argument type is string
d96bb2f66d7 [FLINK-30948][sql-client] Fix ExecutorImpl#testInterruptException hangs (#22055)
8d52415a05b [FLINK-31185][python] Support side-output in broadcast processing
4aacff572a9 [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase
e38a6709b57 [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler
416cb7aaa02 [FLINK-21450][runtime] Restructure types passed between AdaptiveScheduler and SlotAssigner
676e8e5528f [FLINK-21450][runtime] Add previous ExecutionGraph to WaitingForResources AdaptiveScheduler state
d718342ad03 [hotfix][tests] Make LocalRecoveryITCase fail when allocations don't match
18c73f1488b [docs][hotfix] correct label in config configuration
d04090c34b6 [hotfix][doc] to_timestamp() should use order_time_string column instead of order_time
382148e1229 [FLINK-31288][doc] Update doc ralated to overdraft buffer.
70c2ab65ade [FLINK-31288][runtime] Disable overdraft buffer for non pipelined result partition.
b4d43b47c99 [FLINK-30989][table] Fix some options don't take effect in batch mode
758ce721589 [FLINK-29852][Runtime] Fix AdaptiveScheduler add operator repeatedly in json plan.
1993ad0c968 [FLINK-30517][log]Decrease log output interval while waiting for YARN JobManager be allocated.
ab4e85e8bda [FLINK-31286][python] Make sure Python processes are cleaned up when TaskManager crashes
95dd5423aad [FLINK-31222][flink-yarn] Remove usage of deprecated ConverterUtils.toApplicationId. (#22020)
49b8726850c [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader
753734f0a1a [FLINK-31272][python] Handle properly for SinkTransformation to avoid duplicate operators introduced by chaining optimization
33da5908955 [FLINK-31257][docs-zh] Fix errors in “CSV Formats" page
28e75620db7 [FLINK-29859][e2e] Running TPC-DS with adaptive batch scheduler supports custom errors check.
161014149e8 [FLINK-31250][formats][parquet] Parquet format supports MULTISET type
150f2765c96 [FLINK-31221][hotfix] Fix Typo in YarnConfigOptions (#22019)
6797d6f2592 [FLINK-31237][table] Use ExpressionEvaluator in ARRAY_DISTINCT to call SQL compliant equals function.
9493f5fb23a [hotfix] Clean up code of HsResultPartition, PrioritizedDeque and SortMergeSubpartitionReader.
3b6816e0a6c [hotfix] Fix some typo and syntax mistakes.
5c5cc9dbcc1 [hotfix] Add missing @GuardedBy annotation for SortMergeResultPartitionReadScheduler and PipelinedSubpartition.
455b449731d [FLINK-27995][table] Upgrade Janino version to 3.1.9
eb17ec3f05d [FLINK-31077][runtime] Mark pending checkpoint onCompletionPromise complete only after the completed checkpoint is added to the checkpoint store.
c9f1e89b485 [hotfix] Migrate PendingCheckpointTest to Junit5 and AssertJ.
0351f88cea2 [hotfix] Migrate DefaultSchedulerTest to Junit5 and AssertJ.
2e0efe4e072 [FLINK-30277][python]Allow PYTHONPATH of Python Worker configurable
a98bb9a6c97 [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring
eb4106a166f [hotfix] Migrate StreamTaskTest to Junit5 and Assertj
78136133fbe [FLINK-31109][Yarn] Support Hadoop proxy user when delegation token fetch is disabled. This closes #22009
a72f88f3650 [FLINK-30396][table-planner] Fix incorrect hint propagation into sub-query of lookup join hint
464ded1c2a0 [FLINK-31142][Table SQL/Client] Catch TokenMgrError in SqlCommandParserImpl#scan
b987ae18d0b [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase
738b53f1a07 [FLINK-31114][runtime] Refactor the package path of ForwardGroup
67bd4ba7f30 [FLINK-27115][blob] Enrich the error log with remote address for blob server.
f244945aa7c [FLINK-31123][connector/files] Add IT case for FileSink speculative execution
db6e01e028e [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution
b252abe179b [FLINK-31176][sql-gateway] Correct the description of sql gateway configuration (#21983)
dec3ba078de [FLINK-31136][sql-client] Forbid sql client to read executor config in the gateway mode (#21987)
fa6a2aed613 [FLINK-31120] Add concurrent access control for collectorIterators in  StreamExecutionEnvironment
2e91543836d [FLINK-31132][hive] Let hive compact operator without setting parallelism subject to sink operator's configured parallelism.
19cd158ccd1 [hotfix][test] Migrate HiveTableCompactSinkTICase, HiveTableFactoryTest, HiveTableSinkITCase to Junit5 and AssertJ.
cf4ccb73d94 [hotfix] Fix typo in HiveTableSink and HiveTableCompactSinkITCase.
d7cae5365d7 [FLINK-31169][k8s] Fix that pod termination may be mis-treated as fatal error.
3fc3527dc80 [FLINK-31045][clients][tests] Rework test user jar assembly
91f3496690e [hotfix][tests] Remove unused fields
3a64195c495 [FLINK-31175][doc] Fix link doesn't work in hive_read_write doc (#21988)
b3e14928e81 [FLINK-31041][runtime] Fix multiple restoreState when GlobalFailure occurs in a short period.
14adc1679fb [FLINK-31091][sql-gateway] Add Ser/de for Interval types (#21945)
5cda70d873c [FLINK-31113][orc] Support AND filter push down in orc
0508d82ae93 [FLINK-31137][hive] Fix wrong ResultKind in DescribeTable and ShowCreateTable results (#21980)
da00b9c7de7 [FLINK-30968][sql-client] Sql client supports dynamic config to open session (#21901)
3f65eea14a7 [hotfix][docs] Update outdated documentation of windowing support in Python DataStream API
29f009b7e8c [FLINK-30948][Formats/AWS] Remove GlueSchemaRegistry Avro and JSON formats from main repository
bacdc326b58 [FLINK-21000][runtime] Add tests for the InternalSplitEnumeratorMetricGroup This closes #21952.
f04e6de0057 [FLINK-21000][runtime] Provide internal split enumerator metric group
6fae8b58a49 [FLINK-31036][test][checkpoint] FileSystemCheckpointStorage as the default for test
43f419d0ecc [hotfix][doc] Fix documentation of table's configuration option 'table.exec.sink.keyed-shuffle' in ExecutionConfigOptions
d3902e70dfd [FLINK-31119][tests] Use even # of slots
aeac88b1abe [hotfix][tests] Remove unused class
afdc079465c [FLINK-30824][hive] Add document for option 'table.exec.hive.native-agg-function.enabled'
804072aef4f [FLINK-31130][doc] Improve version info shown in the doc of SQL Gateway
9b92a89c185 [FLINK-30908][Yarn] Fix YarnResourceManagerDrivers handling error callbacks after being terminated.
296ee78efdd [FLINK-30908][k8s][yarn] Fix potential uncaught exception in k8s/yarn resource allocation.
001adbe1fc8 [hotfix] Minor clean-ups in ResourceManagerDriverTestBase and YarnResourceManagerDriverTest.
919d46ef914 [FLINK-31017][FLINK-31042][cep] Fix no after-match processing when pattern timeout
55b927b0e6e [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'
81aebd85580 [FLINK-31082][table-planner] Fix for setting maven property 'flink.resueForks' to false in table planner module in right way
1c0870ae087 [FLINK-31055][runtime] Fix the bug that dynamic flag of stream graph does not take effect when translating the transformations
c4231104993 [hotfix] Refactor code to configure stream graph at the same location
9c2156064df [hotfix] Fix the missing parameter error in ForwardForConsecutiveHashPartitionerTest
97e1dbc90cc [FLINK-30895][coordination] Dynamically adjust slot distribution
7bebd2d9fac [FLINK-29801][metrics] Add OperatorCoordinator metric group
ca770b3d905 [FLINK-31099][python] Fix chained WindowOperator throws NPE in PyFlink Thread Mode
756eeee8628 [FLINK-27800][streaming] Fix the error check in StreamNode#addInEdge
e609642abc0 [hotfix][doc]Fix typo in zh/docs/dev/datastream/overview.md
b9f6a90a9f9 [FLINK-27471][table] Add ARRAY_DISTINCT function
d7be0ca8cfe [FLINK-30928][tests] Change to eclipse-temurin due to openjdk deprecation
4595762f974 [FLINK-30257] fix SqlClientITCase#testMatchRecognize
e292a105eb9 [FLINK-31086][doc] Update connector lable for blackhole and kafka (#21846)
29d23fd8a02 [hotfix] Build docs script already contains inits (#21944)
3b8951e91a9 [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module
a0e9e670701 [FLINK-31083][python] Make sure OutputTag._j_output_tag is initialized during unpickle
29b1be61fef [FLINK-31083][python] Allow OutputTag to be reused
d24760b35d9 [FLINK-30251] Move the IO with DFS during abort checkpoint to an asynchronous thread pool
c03efae07b6 [FLINK-30025][table][test] remove same amount of "-" and " " after node ids have been removed because the ids might have different length in different envs.
4cdbfee2be4 [FLINK-30025][table][test] split streaming and batch test queries. Test SET 'table.display.max-column-width'
e3f50194fa6 [FLINK-30025][table] fix print batch result and deprecate ConfigOption.DISPLAY_MAX_COLUMN_WIDTH
91d6fa21de4 [FLINK-30025][table] add new table config option to resize the max column width while printing the query result to the client console.
bf0ad52cbcb [FLINK-30629][test] Set CLIENT_ALIVENESS_CHECK_DURATION to clientHeartbeatInterval for ClientHeartbeatTest#testJobCancelledIfClientHeartbeatTimeout.
00e1ef38f98 [FLINK-28658][docs] Add docs for job statements
3856c49af77 [FLINK-30690][javadocs] Fix java documentation and some word spelling errors (#21675)
057dbc5f62a [FLINK-31015][connectors/common] Fix SplitReader doesn't extends AutoCloseable but implements close method
1e8d528e293 [FLINK-28786][following][python] Fix PyFlink execution failure on Mac Os with M1 chip
d6f4e066545 [hotfix][docs] Fix typo in explain.md
845d04d07d6 [FLINK-30864][FLINK-30885][CEP] Fix wrong NFA related to optional decoration at the beginning of group pattern
5ceda3da20e [FLINK-30860][doc] Add document for hybrid shuffle with adaptive batch scheduler.
b89f060892c [hotfix] Fix incorrect url link in batch_shuffle.md.
b3998324b68 [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism
2fc90245f57 [hotfix] Adjust the parameters of AdaptiveBatchSchedulerITCase to make tests more reasonable
e67b141f2b2 [FLINK-30961][python] Remove deprecated "tests_require" in setup.py (#21893)
50c522f1d81 [FLINK-30962][python] Improve the error message during launching py4j gateway server
3a647d6bec7 [FLINK-25813][table-planner] Fix unstable test TableITCase#testCollectWithClose
c0aa73df4df [FLINK-28440][state/changelog] record reference count of StreamStateHandle in TaskChangelogRegistry
e22f06130a8 [FLINK-31031][python] Disable the output buffer of Python process
c096c03df70 [FLINK-30969][python] Remove the __init__.py files under the examples
a92892fea74 [FLINK-30981][python] Fix explain_sql throws method not exist exception
cc94a1d1855 [hotfix][doc] Fix typo in elastic_scaling.md
ba2b55df207 [FLINK-30561][state/changelog] fix changelog local cache file not found
ffecb68b11e [FLINK-30904][docs] Update the documentation and configuration description of slow task detector.
d7bbb763ded [FLINK-30785][tests] Ignore completeExceptionally in e2e test logs
d9102ddd755 [FLINK-29237][table] Remove RexSimplify from Flink code, SearchOperator code generation for RexUnknown.nullAs
ae89c997fa7 [FLINK-30712][docs][network] Update documents for taskmanager memory configurations and tuning
62f98be34a1 [hotfix] Add infinite annotations for the configurations with the default maximum value
5a4e0ea31ae [FLINK-30942][runtime] Eagerly sets the parallelism of job vertices in the parallelism-decided forward groups.
040a72b9fcb [hotfix] Migrate related tests to Junit5
8ff06420312 [FLINK-30940][sql-client] Redirect the interrupted exception to the log (#21891)
df23acfc0f1 [FLINK-30944] Fix thread leak in ExecutionGraphPartitionReleaseTest.
82ba1f7ab21 [hotfix] Introduce Junit5 extension for TestingComponentMainThreadExecutor.
7bdc7549fdf [hotfix] Migrate ExecutionGraphPartitionReleaseTest to Junit5 and AssertJ.
4029f730e45 [FLINK-30972][e2e] Update libssl download link
4fb5f5e48ae [FLINK-30902][runtime] Change reusable hybrid result partition to hybrid full to enable partition reuse optimization.
dabc3ba5777 [FLINK-30392][runtime] Change broadcast hybrid selective result partition type to hybrid full in compile phase instead of partition create phase. In the previous implementation, we will force the broadcast hybrid selective edge to be of hybrid full(re-consumable) in the ResultPartitionTypeFactory. But this is not the correct phase to do this replacement, because for scheduling topology, the result is not changed still. This inconsistency will cause many problems, such as increasing the cost of fail-over.
14b9f793f41 [hotfix] fix not incorrect comment in testIntermediateDataSetReuse.
2ad9585f47f [FLINK-30629][Client/Job Submission] Fix the unstable test ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat
a6c84cd2cb3 [FLINK-30838][doc] Update documentation of AdaptiveBatchScheduler
550697af3df [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase (#21892)
e33034f8aa3 [FLINK-30958][rest][docs] Fix REST API doc generation failure caused by JobClientHeartbeatHeaders
bf68aa2fd93 [FLINK-30837] Remove use of MutableByteArrayInputStream
76a6edc7ff2 [FLINK-30925][docs] Add docs about sql-client remote mode
bd33e02547e [FLINK-30925][docs] Update sql-gateway open api doc
a6de5f23a30 [FLINK-30910][runtime] Making test wait for stop to be called before finishing the bootstrap operation (#21869)
20570985e0b [hotfix][test] Makes ServerSocket being closed after the ZooKeeperLeaderRetrievalTest.testConnectingAddressRetrievalWithDelayedLeaderElection ran
cba2e1e433e [FLINK-30801][runtime] Migrates LeaderElection- and LeaderRetrieval-related tests in flink-runtime to JUnit5
c22c2cd55ef [FLINK-22320][docs][table] Add documentation for new introduced ALTER TABLE statements
10ced269a8e [FLINK-30901][runtime] Fix the jobVertex's parallelismConfigured is incorrect when chaining with source operators
54967e9124b [FLINK-30788][runtime] Refactors AbstractHaServices.createLeaderElectionService to return LeaderElectionDriverFactory
96a296db723 [FLINK-30927][TableSQL/Runtime] - Bug fix for FLINK-30927 - rewritten conde failed at compilation with "non-abstract methods have the same parameter types, declaring type and return type"
d76c49b497c [hotfix][release] Add 1.18 to the flink version enum
923361a3006 Update version to 1.18-SNAPSHOT

Screenshots / Logs

No response

Software information

• Operating system: macOS
• Rust version: stable
• Project version: git-cliff 2.2.0

Additional context

No response

[welcome[bot]]

Thanks for opening your first issue at git-cliff! Be sure to follow the issue template! ⛰️

[tisonkun]

Let me think of it ... It means other commits doesn't follow the conventional commit pattern so get skipped?

[tisonkun]

This should be the case.

After set filter_unconventional = false and add { message = "\\[", group = "<!-- 0 -->🚀 Features" }, to commit_parsers, it can select the proper range of commits.

[orhun]

Glad that this is resolved! Let me know if there is anything else.