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 2826ff8 [FLINK-12374][table-planner-blink] Support translation from
StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation.
(#8407)
new 6231b18 [FLINK-12472][yarn] Support setting
attemptFailuresValidityInterval of jobs on Yarn
new b3f102d [FLINK-12468][yarn] Unregister application from the YARN
Resource Manager with a valid appTrackingUrl
new 792f2a2 [FLINK-12468][yarn] Derive HistoryServer's URL from
HistoryServerOptions
new 07773d0 [FLINK-12260] Slot allocation failure by taskmanager
registration timeout and race
new 2284f77 [FLINK-12260][tests] Speed up
ResourceManagerTaskExecutorTest#testDelayedRegisterTaskExecutor
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/yarn_config_configuration.html | 5 +
.../runtime/webmonitor/history/HistoryServer.java | 2 +-
.../runtime/resourcemanager/ResourceManager.java | 27 +++--
.../webmonitor/history/HistoryServerUtils.java | 82 +++++++++++++++
.../ResourceManagerTaskExecutorTest.java | 68 +++++++++++-
.../flink/runtime/rpc/TestingRpcService.java | 22 +++-
.../webmonitor/history/HistoryServerUtilsTest.java | 114 +++++++++++++++++++++
.../flink/yarn/AbstractYarnClusterDescriptor.java | 6 +-
.../org/apache/flink/yarn/YarnResourceManager.java | 9 +-
.../yarn/configuration/YarnConfigOptions.java | 13 +++
10 files changed, 333 insertions(+), 15 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerUtilsTest.java
