You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/02 20:49:00 UTC

[jira] [Created] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name

Igal Shilman created FLINK-25936:
------------------------------------

             Summary: MutableTypeCell is not setting correctly the value's type_name
                 Key: FLINK-25936
                 URL: https://issues.apache.org/jira/browse/FLINK-25936
             Project: Flink
          Issue Type: Improvement
            Reporter: Igal Shilman


In the remote Java SDK, when a type doesn't specify an IMMUTABLE_VALUE type characteristics, (which is the case for custom type implementations by default) the type_name field is not set correctly on the resulting TypedValue.

A MutableTypeCell was assuming incorrectly that the backend will send a TypedValue with a type_name field set even if the value is missing (TypedValue.has_value = false). This is not the case, and hence the type_name needs to be set explicitly.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)