[FLINK-27676][python] Fix on_timer output behind triggering watermark

This closes #19765.

[FLINK-27185][connector] Convert connector-cassandra module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>

[FLINK-27680][Connector][Pulsar] Disable PulsarSinkITCase and PulsarSourceITCase on JDK 11 since Pulsar doesn't support JDK 11 fully

[FLINK-27682][tests] Migrate ComparatorTestBase to JUnit5

[FLINK-27340][python][tests] Migrate flink-python to JUnit5

[FLINK-25795][python][connector/pulsar] Support pulsar sink connector in PyFlink DataStream API

This closes #19682.

[FLINK-27185][connector] Convert connector-base module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>

[FLINK-27185][connector] Convert connector-hive module to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>

[FLINK-27185][connector] Convert connector-elasticsearch modules to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>

[FLINK-27607][tests] Migrate module flink-connector-files to JUnit5

[FLINK-27673][table][tests] Migrate flink-table-api-scala to JUnit5

[FLINK-27669][tests] Migrate flink-file-sink-common to JUnit5

[FLINK-27561][aws][tests] Migrate connector-aws-base to JUnit5

[hotfix][python] Fix lint-python typo

[FLINK-24433][Connector][Elasticsearch] Disable Elasticsearch disk allocation decider. Elasticsearch by default goes into read-only mode when the disk usage is above 85%. On the Azure E2E tests, this is quite common.

We therefore disable the entire disk allocation decider, as documented on https://www.elastic.co/guide/en/elasticsearch/reference/6.2/disk-allocator.html

 [FLINK-27662][tests] Migrate TypeInformationTestBase to JUnit5

[hotfix][akka][docs] Replace LocalRpcInvocation with RpcInvocation

This closes #8033.

[hotfix][elasticsearch] Fix typo

[FLINK-27059][compress][tests] Migrate tests to JUnit5

[FLINK-25543][yarn][tests] Migrate tests to JUnit5

[FLINK-27433][tests] Store RocksDB logs in its database folder for e2e tests

[FLINK-27567][aws][tests] Migrate connector-aws-kinesis-streams to JUnit5

[FLINK-27501][tests] Migrate SerializerTestBase to JUnit5

[FLINK-26909][Client/Job Submission] Allow to set parallelism to be -1 from Cli

This closes #19651.

[hotfix][table] Add objectReuse parameter for AsyncLookupJoinITCase. (#19728)

[FLINK-27649][connectors/elasticsearch] Remove slf4 dependency causing unwanted log output

[FLINK-24433][Tests][Buildsystem] Remove additional pre-installed packages to clean up more diskspace before starting the E2E tests. Also removing the line that removes `^ghc-8.*` since that doesn't exist anymore on the machines.

[FLINK-27566][aws][tests] Migrate aws-kinesis-firehose to JUnit5

[FLINK-27323][table][tests] Migrate table-api-java to JUnit5

[FLINK-17232][k8s] Disable the implicit behavior to use the Service externalIP as the address of the Endpoint

[FLINK-24433][Tests][Buildsystem] Turn off debug logging for all end-to-end tests to avoid flooding the disk space

[FLINK-27271][python] Expose GroupWindow to users

[FLINK-27564][python] Separate different connectors into separate packages

This closes #19711.

[FLINK-27185][formats] Convert format modules to assertj

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>

[FLINK-27271][python] Introduce Globalwindows window allocator

This closes #19696.

[FLINK-26206][runtime-web] add service layer abstraction and refactor config service

[hotfix][docs] Fix the wrong display of totalNumberOfCheckpoints in metric.md

[FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization

[FLINK-27421][python] Bundle test utility classes (#19700)

[FLINK-27560][python] Refactor SimpleStateRequestHandler to support both keyed state and operator state

This closes #19687.

[hotfix][connector][elasticsearch] Reduce testutils log level (#19707)

[FLINK-27297][python] Add get_execution_environment method with configuration argument.

This closes #19685.

[hotfix][table] avoid NPE and add more UTs. Remove System.out.println() call.

This closes #19699.

FLINK-27260][Runtime/Web] Expose changelog configurations in web ui

[FLINK-27260][Runtime/REST] Expose changelog configurations in Rest API

[hotfix][docs]correct configuration key "taskmanager.network.detailed-metrics" in metrics document

[hotfix][docs] fix "parameters"

[hotfix][connectors/kafka] Fix spelling of setDeliveryGuarantee method

[hotfix][doc] Extensible unified Sink uses new metric to capture outgoing records

[FLINK-27563][docs] Fix yarn doc page display error.

[FLINK-27048][test] Add ArchUnit rule that connectors should only depend on public API

[FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

[FLINK-27565][runtime-web] Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard. This closes #19501

Bumps [minimist](https://github.com/substack/minimist) from 1.2.5 to 1.2.6.
- [Release notes](https://github.com/substack/minimist/releases)
- [Commits](https://github.com/substack/minimist/compare/1.2.5...1.2.6)

---
updated-dependencies:
- dependency-name: minimist
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <support@github.com>

[FLINK-27255] [flink-avro] flink-avro does not support ser/de of large avro schema (#19645)

Co-authored-by: Haizhou Zhao <haizhou_zhao@apple.com>

[hotfix][docs-zh] Fix two inaccessible links. (#19678)

* [hotfix][docs-zh] Fix two inaccessible links to the Iterations documentation. This fixes #19678

[FLINK-27487][kafka] Only forward measurable Kafka metrics and ignore others

[hotfix] Fix comment typos in AsyncIOExample

[FLINK-26588][docs] Translate the new CAST documentation to Chinese

This closes #19498.

[FLINK-26112][k8s]Port getRestEndpoint method to the specific service type subclass

This closes #18762.

[Flink-26112][k8s]Refactor the FlinkKubeClient interface to deal with service name directly

[hotfix]Remove unused variable in KubernetesEntrypointUtils

[hotfix][table][tests] Replace ExpectedException with assertJ

Replace deprecated ExpectedException with assertJ's
`assertThatThrownBy` and improve certain assertions by asserting
the Exception class or the Exception message where missing.

This closes #19262.

[hotfix][table][tests] Clean-up tests and update to assertJ

[hotfix][table-planner][tests] Remove configuration for default legacy-cast-behaviour

Since `table.exec.legacy-cast-behaviour` is disabled by default, there
is no need to explicitely set it in the configuration of the Cast
related IT tests.

Call `super.getConfiguration()` to inherit the configuration set in the
superclass and add/override with more config options in the subclass.

[hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes.

This closes #19676

[hotfix][docs] Fix the formatting errors of some Chinese documents.

[FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsException in docs

[hotfix][docs-zh] Add known issues with Pulsar client under Java 11 to Chinese documentation.

[FLINK-27545][python][examples] Update the example in PyFlink shell

This closes #19673.

[hotfix][doc] fix the mismatch result in Window Join example (#19665)

Signed-off-by: TennyZhuang <zty0826@gmail.com>

[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots

[release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase and create snapshots

[release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and create snapshots

[release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase and create snapshots

[release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots

[release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase and create snapshots

[release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for CEPMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for ContinuousFileProcessingMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for FlinkKinesisConsumerMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for FlinkKafkaProducerMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest and create snapshots

[release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots

[FLINK-27461][Kubernetes] Add option to set userAgent for kubeclient

This closes #19630.

[FLINK-27476][tests] Add dedicated import option for selecting production code

[hotfix][docs] Fix the inaccessible huawei cloud  link.

[FLINK-27533][coordination][tests] Remove retry attempt limit

The test could fail if the polling loop ran too quickly or if the timing was just right that it always missed the restarting state.
Remove the limit and just wait for as long as needed.

[hotfix][docs-zh] Delete redundant English content in Chinese documents.

[FLINK-24820][docs] Wrong description in documentation for IS DISTINCT FROM

[release] Change the stable doc versions

[FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

This closes #19615

[FLINK-27469][yarn][tests] Drop CliFrontendRunWithYarnTest

The detached/parallelism options aren't handled by the yarn session CLI.
See CliFrontendParser#getProgramSpecificOptions.

[FLINK-26052][docs-zh] Document savepoint format

[FLINK-27477][yarn][tests] Drop flink-yarn test-jar

[release] Add 1.15 docs link to the list of previous versions

[hotfix][ci] Update libssl download link

[FLINK-27486][tests] Fix archunit test violations in connector-base module

[FLINK-27486][hybrid] Make hybrid source building blocks as PublicEvolving

[FLINK-27486][core] Mark documentation formatting tools as PublicEvolving

[hotfix][k8s][tests] Fix import