You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/02/28 03:25:32 UTC
[flink] branch release-1.10 updated: [FLINK-16301][table-api]
Improve logging message in ModuleManager (#11244)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new f800753 [FLINK-16301][table-api] Improve logging message in ModuleManager (#11244)
f800753 is described below
commit f800753865eecaea313cfd154dc240090d45fc87
Author: Jark Wu <ja...@apache.org>
AuthorDate: Fri Feb 28 11:20:13 2020 +0800
[FLINK-16301][table-api] Improve logging message in ModuleManager (#11244)
---
.../src/main/java/org/apache/flink/table/module/ModuleManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java
index 96a5995..2a885d9 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java
@@ -126,11 +126,11 @@ public class ModuleManager {
.findFirst();
if (result.isPresent()) {
- LOG.info("Got FunctionDefinition {} from module {}", name, result.get().getKey());
+ LOG.info("Got FunctionDefinition '{}' from '{}' module.", name, result.get().getKey());
return result.get().getValue().getFunctionDefinition(name);
} else {
- LOG.info("Cannot find FunctionDefinition {} from any loaded modules", name);
+ LOG.debug("Cannot find FunctionDefinition '{}' from any loaded modules.", name);
return Optional.empty();
}