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 2022/02/08 10:04:15 UTC
[flink] branch master updated: [FLINK-25956][kryo] Remove noisy warnings
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 557750a [FLINK-25956][kryo] Remove noisy warnings
557750a is described below
commit 557750a88a39138b54f233fec4e5e344d6967936
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Fri Feb 4 09:47:35 2022 +0100
[FLINK-25956][kryo] Remove noisy warnings
---
.../flink/api/java/typeutils/runtime/kryo/KryoSerializer.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
index 7eaf169..b7858d1 100644
--- a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
+++ b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
@@ -496,9 +496,11 @@ public class KryoSerializer<T> extends TypeSerializer<T> {
| IllegalAccessException
| InvocationTargetException e) {
- LOG.warn(
- "Falling back to default Kryo serializer because Chill serializer couldn't be found.",
- e);
+ if (LOG.isDebugEnabled()) {
+ LOG.info("Kryo serializer scala extensions are not available.", e);
+ } else {
+ LOG.info("Kryo serializer scala extensions are not available.");
+ }
Kryo.DefaultInstantiatorStrategy initStrategy = new Kryo.DefaultInstantiatorStrategy();
initStrategy.setFallbackInstantiatorStrategy(new StdInstantiatorStrategy());