This closes #11575

Clearing the rpcConnection field in the JobManagerLeaderListener when target loses leadership
prevents that we try to reconnect to the target in case JobLeaderService.reconnect(JobID) is
called.

This closes #11552.

This commit fixes a bug where we did not update the state of the AkkaRpcActor
in case of terminating it. Moreover, this commit fixes the problem that the
onStop action could have been called multiple times. Last but not least, it
changes the enum names of the state implementations for better diagnostics.

This closes #11549.

In order to not fail the job submission with a TimeoutException if
it takes longer than 10 s, this commit increases the web.timeout to
10 minutes.

This closes #11565.

Because the classloader is now closed when the task fails the UDF only has access to the bootstrap classloader, which doesn't contain our own test classes.

Allows user classloader can be unloaded even if a reference on the context classloader outlives the user code.

The test is actually testing FlinkUserCodeClassLoaders.

This closes #11504

This closes #11560

* Some join order changes for blink-planner due to the rule fire sequence changes, see https://github.com/apache/calcite/commit/35caa059a762094c7df0b30e9b51358a19b48ac2, they are still correct
* The Correlate row count estimation has been fixed from a always 1 to join like estimation, thus, if the inputs of Join is a Correlate, the join algorithm would very probably changes, i.e. batch.sql.SubplanReuseTest
* Due to CALCITE-3729, the filter condition was pushed down for some Join cases: batch.sql.join.JoinReorderTest
* Due to CALCITE-2450 RexNode normalization, the predicates sequence of some test changes: logical.subquery.FlinkRewriteSubQueryRuleTest
* The Decimal modulus precision inference has been fixed: planner.expressions.DecimalTypeTest

* GROUP_ID translation was fixed

* CALCITE-3763 prunes useless fields of input project

[FLINK-14338][table-planner][table-planner-blink] Update files due to builtin TUMBLE operator name changes to $Tumble

* This change was introduced in CALCITE-3382

[FLINK-14338][table-planner-blink] Plan verify changes from DIGEST to EXPLAIN: change plan for values node

* The values node does not print row type anymore

[FLINK-14338][table-planner-blink] Plan verify changes from DIGEST to EXPLAIN: change plan for expand node

* The explain node does not show each projects names anymore

* Because of CALCITE-3713, the project names was removed from plan DIGEST, thus, the DIGEST plan has less info that EXPLAIN, we switch to EXPLAIN for plan verification;
* The CALC window fields name was also changes with CALCITE-3713, which is acceptable because the old name was also un-readable, the new name was based on field index, not bad.

[FLINK-14338][table-planner][table-planner-blink] Remove redundant code copy because the bugs are already fixed in Calcite

* SqlValidatorImpl.java was removed because of CALCITE-2707
* ParameterScope.java was removed because of CALCITE-3476
* SqlFunction.java was removed because of CALCITE-3360

* Replace RelOptUtils.createCastRel with RelOptUtil.createCastRel
* Implement RelOptTable#getKeys and Statistic#getKeys
* Changes logical nodes constructor for hints
* Implement RelShuttle.visit(LogicalTableModify)

[FLINK-14338][table-planner][table-planner-blink] Remove usage of TableScanRule and use new TableScanFactory extension

* This change was introduced in CALCITE-3769

* This feature is introduced in CALCITE-3446

* Add Junit5 supports for tests
* Move classes under package calcite.sql to flink.sql.parser.type
* Remove ExtendedSqlBasicTypeNameSpec, use SqlAlienSystemTypeNameSpec instead
* In Parser.tdd, re-organize the imports order to alphabetical order, remove the useless tailing commas, extends nonReservedKeywordsToAdd
* Fix the JavaCC compile warnings

This closes #11340

This closes #11498.

This closes #11516.

[FLINK-16672][python] Support Counter, Gauge, Meter, Distribution metric type for Python UDF (#11543)

This closes #11550

This closes #11158

[FLINK-16262][connectors/kafka] Set the context classloader for parallel stream in FlinkKafkaProducer

This closes #11247