[flink] branch release-1.10 updated (e44f2d6 -> 1627a1a)

[tr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from e44f2d6  [FLINK-15380][scala-shell] Unable to set number of TM and number of Slot for MiniCluster in Scala shell
     add 8171e4d  [hotfix][core][config] Use the new type definition for config options of primitive types in TaskManagerOptions.
     add 8511204  [FLINK-15371][core][config] Use the new type definition for config options of memory types in TaskManagerOptions.
     add 1627a1a  [hotfix][core][config] Use the new type definition for config options of duration types in TaskManagerOptions.

No new revisions were added by this update.

Summary of changes:
 docs/_includes/generated/common_section.html       |  2 +-
 .../generated/task_manager_configuration.html      | 16 ++--
 .../task_manager_memory_configuration.html         | 44 +++++-----
 .../kafka/KafkaShortRetentionTestBase.java         |  3 +-
 .../streaming/connectors/kafka/KafkaTestBase.java  |  3 +-
 .../kinesis/manualtests/ManualExactlyOnceTest.java |  3 +-
 .../ManualExactlyOnceWithStreamReshardingTest.java |  3 +-
 .../flink/configuration/TaskManagerOptions.java    | 96 +++++++++++++++-------
 .../kubernetes/KubernetesResourceManagerTest.java  |  3 +-
 .../flink/kubernetes/KubernetesSessionCliTest.java |  7 +-
 .../MesosTaskManagerParameters.java                |  2 +-
 .../LaunchableMesosWorkerTest.java                 |  2 +-
 .../MesosTaskManagerParametersTest.java            |  5 +-
 .../itcases/HAQueryableStateFsBackendITCase.java   |  3 +-
 .../HAQueryableStateRocksDBBackendITCase.java      |  3 +-
 .../NonHAQueryableStateFsBackendITCase.java        |  3 +-
 .../NonHAQueryableStateRocksDBBackendITCase.java   |  3 +-
 .../runtime/webmonitor/WebFrontendITCase.java      |  7 +-
 .../TaskExecutorResourceSpecBuilder.java           |  2 +-
 .../TaskExecutorResourceUtils.java                 |  6 +-
 .../ActiveResourceManagerFactory.java              |  2 +-
 .../taskexecutor/TaskManagerConfiguration.java     |  9 +-
 .../runtime/util/ConfigurationParserUtils.java     |  5 +-
 .../TaskExecutorResourceUtilsTest.java             | 90 ++++++++++----------
 .../ActiveResourceManagerFactoryTest.java          |  3 +-
 .../StandaloneResourceManagerFactoryTest.java      |  2 +-
 .../TaskExecutorLocalStateStoresManagerTest.java   |  3 +-
 .../NettyShuffleEnvironmentConfigurationTest.java  |  2 +-
 .../TaskExecutorPartitionLifecycleTest.java        |  3 +-
 .../taskexecutor/TaskExecutorSubmissionTest.java   |  5 +-
 .../runtime/taskexecutor/TaskExecutorTest.java     |  5 +-
 .../TaskManagerRunnerConfigurationTest.java        |  3 +-
 .../taskexecutor/TaskManagerRunnerStartupTest.java |  9 +-
 .../taskexecutor/TaskManagerRunnerTest.java        |  8 +-
 .../TaskSubmissionTestEnvironment.java             |  3 +-
 .../TaskCancelAsyncProducerConsumerITCase.java     |  3 +-
 .../runtime/testutils/MiniClusterResource.java     |  5 +-
 .../runtime/util/JvmExitOnFatalErrorTest.java      |  3 +-
 .../client/gateway/local/LocalExecutorITCase.java  |  3 +-
 .../runtime/utils/BatchAbstractTestBase.java       |  3 +-
 .../test/accumulators/AccumulatorErrorITCase.java  |  3 +-
 .../flink/test/cancelling/CancelingTestBase.java   |  3 +-
 .../EventTimeAllWindowCheckpointingITCase.java     |  3 +-
 .../EventTimeWindowCheckpointingITCase.java        |  3 +-
 .../KeyedStateCheckpointingITCase.java             |  3 +-
 .../flink/test/checkpointing/SavepointITCase.java  |  3 +-
 .../checkpointing/WindowCheckpointingITCase.java   |  3 +-
 .../flink/test/classloading/ClassLoaderITCase.java |  3 +-
 .../example/failing/JobSubmissionFailsITCase.java  |  5 +-
 .../manual/StreamingScalabilityAndLatency.java     |  3 +-
 .../flink/test/misc/CustomSerializationITCase.java |  3 +-
 .../SuccessAfterNetworkBuffersFailureITCase.java   |  3 +-
 ...tractTaskManagerProcessFailureRecoveryTest.java |  5 +-
 .../JobManagerHAProcessFailureRecoveryITCase.java  |  5 +-
 .../recovery/ProcessFailureCancelingITCase.java    |  5 +-
 .../flink/test/runtime/FileBufferReaderITCase.java |  3 +-
 .../flink/test/runtime/IPv6HostnamesITCase.java    |  3 +-
 .../flink/test/runtime/SchedulingITCase.java       |  3 +-
 .../test/runtime/ShuffleCompressionITCase.java     |  3 +-
 .../test/streaming/runtime/BackPressureITCase.java |  9 +-
 .../test/streaming/runtime/TimestampITCase.java    |  3 +-
 .../flink/yarn/CliFrontendRunWithYarnTest.java     |  3 +-
 .../apache/flink/yarn/YarnClusterDescriptor.java   |  4 +-
 .../apache/flink/yarn/cli/FlinkYarnSessionCli.java |  2 +-
 .../apache/flink/yarn/FlinkYarnSessionCliTest.java |  7 +-
 .../apache/flink/yarn/YarnResourceManagerTest.java |  3 +-
 66 files changed, 282 insertions(+), 199 deletions(-)