This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a9839f3 [FLINK-15380][scala-shell] Unable to set number of TM and
number of Slot for MiniCluster in Scala shell
add bec32a3 [hotfix][core][config] Use the new type definition for config
options of primitive types in TaskManagerOptions.
add 702a016 [FLINK-15371][core][config] Use the new type definition for
config options of memory types in TaskManagerOptions.
add 29c718d [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(-)
