You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/04/14 11:41:57 UTC
[flink] branch master updated (da22f75 -> f2f2bef)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from da22f75 [FLINK-22063][table] Fix bug that some join conditions are lost when building Lookup Join ExecNode
add df808f1 [FLINK-22212][coordination] Refactor resource requirement logging
add 9e33c15 [FLINK-22211][datastream] Only log exceptions if job has been initialized
add d711845 [FLINK-22214][runtime] Refactor CheckpointStorageLoader
add 9e5f39e [FLINK-22218][runtime] Silence sending of null input split
add 2d80d8e [FLINK-22219][coordination] Reduce duplicate ExternalResource logging
add 43db36a [FLINK-22216][coordination] Log start of RM instead of SlotManager on info
add ba520fa [FLINK-22210][task] Log conversion of input channels on DEBUG
add 6434fc5 [FLINK-22220][task] Log task registration at network on DEBUG
add f2f2bef [FLINK-22213][filesystem] Do not log factory hashcodes
No new revisions were added by this update.
Summary of changes:
.../api/common/io/DefaultInputSplitAssigner.java | 4 +-
.../api/common/io/LocatableInputSplitAssigner.java | 6 ---
.../java/org/apache/flink/core/fs/FileSystem.java | 5 ++-
.../externalresource/ExternalResourceUtils.java | 27 ++++++++++---
.../partition/consumer/SingleInputGate.java | 2 +-
.../runtime/resourcemanager/ResourceManager.java | 6 +--
.../slotmanager/DeclarativeSlotManager.java | 14 ++++---
.../runtime/scheduler/ExecutionGraphHandler.java | 4 +-
.../runtime/state/CheckpointStorageLoader.java | 44 +++++++++++-----------
.../runtime/taskexecutor/TaskManagerRunner.java | 6 +--
.../org/apache/flink/runtime/taskmanager/Task.java | 2 +-
.../operators/collect/CollectResultFetcher.java | 10 ++++-
12 files changed, 75 insertions(+), 55 deletions(-)