Repository: flink
Updated Branches:
  refs/heads/release-1.5 416d924b5 -> 27061d35a


[FLINK-9387] Several log message errors in queryable-state module.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27061d35
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27061d35
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/27061d35

Branch: refs/heads/release-1.5
Commit: 27061d35aa0b97616357317a96f44704e0a5a07c
Parents: 416d924
Author: yanghua <yanghua1...@gmail.com>
Authored: Thu May 17 09:35:29 2018 +0200
Committer: kkloudas <kklou...@gmail.com>
Committed: Thu May 17 18:33:05 2018 +0200

----------------------------------------------------------------------
 .../flink/queryablestate/network/AbstractServerHandler.java      | 2 +-
 .../queryablestate/client/proxy/KvStateClientProxyHandler.java   | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/27061d35/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
----------------------------------------------------------------------
diff --git 
a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
 
b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
index a514723..b2f7a47 100644
--- 
a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
+++ 
b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
@@ -303,7 +303,7 @@ public abstract class AbstractServerHandler<REQ extends 
MessageBody, RESP extend
                                        LOG.debug("Request {} was successfully 
answered after {} ms.", request, durationMillis);
                                        
stats.reportSuccessfulRequest(durationMillis);
                                } else {
-                                       LOG.debug("Request {} failed after {} 
ms : ", request, durationMillis, future.cause());
+                                       LOG.debug("Request {} failed after {} 
ms due to: {}", request, durationMillis, future.cause());
                                        stats.reportFailedRequest();
                                }
                        }

http://git-wip-us.apache.org/repos/asf/flink/blob/27061d35/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
----------------------------------------------------------------------
diff --git 
a/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
 
b/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
index 2e24431..8201305 100644
--- 
a/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
+++ 
b/flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
@@ -197,14 +197,14 @@ public class KvStateClientProxyHandler extends 
AbstractServerHandler<KvStateRequ
                final CompletableFuture<KvStateLocation> cachedFuture = 
lookupCache.get(cacheKey);
 
                if (!forceUpdate && cachedFuture != null && 
!cachedFuture.isCompletedExceptionally()) {
-                       LOG.debug("Retrieving location for state={} of job={} 
from the cache.", jobId, queryableStateName);
+                       LOG.debug("Retrieving location for state={} of job={} 
from the cache.", queryableStateName, jobId);
                        return cachedFuture;
                }
 
                final KvStateLocationOracle kvStateLocationOracle = 
proxy.getKvStateLocationOracle(jobId);
 
                if (kvStateLocationOracle != null) {
-                       LOG.debug("Retrieving location for state={} of job={} 
from the key-value state location oracle.", jobId, queryableStateName);
+                       LOG.debug("Retrieving location for state={} of job={} 
from the key-value state location oracle.", queryableStateName, jobId);
                        final CompletableFuture<KvStateLocation> location = new 
CompletableFuture<>();
                        lookupCache.put(cacheKey, location);
 

Reply via email to