[flink] 10/10: [FLINK-17977][core] Silence type extractor warnings for built-in Row

[chesnay]

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 <ches...@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.");