flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [4/5] flink git commit: [FLINK-8860][flip6] stop SlotManager spamming logs for every TM heartbeat at log level 'info'
Date Fri, 09 Mar 2018 08:41:35 GMT
[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 <nico@data-artisans.com>
Authored: Mon Mar 5 13:55:04 2018 +0100
Committer: zentol <chesnay@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);
 


Mime
View raw message