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 2018/03/09 08:41:35 UTC
[4/5] flink git commit: [FLINK-8860][flip6] stop SlotManager spamming
logs for every TM heartbeat at log level 'info'
[FLINK-8860][flip6] stop SlotManager spamming logs for every TM heartbeat at log level 'info'
This closes #5637.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20194414
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20194414
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/20194414
Branch: refs/heads/release-1.5
Commit: 201944149d48f60282653fdb35bbdd98037f5969
Parents: 15ffb18
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Mon Mar 5 13:55:04 2018 +0100
Committer: zentol <ch...@apache.org>
Committed: Fri Mar 9 09:41:18 2018 +0100
----------------------------------------------------------------------
.../flink/runtime/resourcemanager/slotmanager/SlotManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/20194414/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
index ca33719..43e670e 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
@@ -384,7 +384,7 @@ public class SlotManager implements AutoCloseable {
public boolean reportSlotStatus(InstanceID instanceId, SlotReport slotReport) {
checkInit();
- LOG.info("Received slot report from instance {}.", instanceId);
+ LOG.trace("Received slot report from instance {}.", instanceId);
TaskManagerRegistration taskManagerRegistration = taskManagerRegistrations.get(instanceId);