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 2020/06/12 12:16:08 UTC
[flink] 10/10: [FLINK-17977][core] Silence type extractor warnings
for built-in Row
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 38b822f116424166bc5e5729ccbc0faf139e4bff
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Jun 11 19:18:59 2020 +0200
[FLINK-17977][core] Silence type extractor warnings for built-in Row
---
.../java/org/apache/flink/api/java/typeutils/TypeExtractor.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
index acb1ec9..adcfdbb 100644
--- a/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
+++ b/flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
@@ -1816,10 +1816,10 @@ public class TypeExtractor {
if(hasGetter && hasSetter) {
return true;
} else {
- if(!hasGetter) {
+ if(!hasGetter && clazz != Row.class) {
LOG.info(clazz+" does not contain a getter for field "+f.getName() );
}
- if(!hasSetter) {
+ if(!hasSetter && clazz != Row.class) {
LOG.info(clazz+" does not contain a setter for field "+f.getName() );
}
return false;
@@ -1858,7 +1858,7 @@ public class TypeExtractor {
List<PojoField> pojoFields = new ArrayList<PojoField>();
for (Field field : fields) {
Type fieldType = field.getGenericType();
- if(!isValidPojoField(field, clazz, typeHierarchy)) {
+ if(!isValidPojoField(field, clazz, typeHierarchy) && clazz != Row.class) {
LOG.info("Class " + clazz + " cannot be used as a POJO type because not all fields are valid POJO fields, " +
"and must be processed as GenericType. Please read the Flink documentation " +
"on \"Data Types & Serialization\" for details of the effect on performance.");