[jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality

Shang Yuanchun (Jira)
Márton Balassi created FLINK-5156:
-------------------------------------

             Summary: Consolidate streaming FieldAccessor functionality
                 Key: FLINK-5156
                 URL: https://issues.apache.org/jira/browse/FLINK-5156
             Project: Flink
          Issue Type: Task
            Reporter: Márton Balassi


The streaming FieldAccessors (keyedStream.keyBy(...)) have slightly different semantics compared to their batch counterparts.

Currently the streaming ones allow selecting a field within an array (which might be dangerous as the array typeinfo does not contain the length of the array, thus leading to a potential index out of bounds) and accept not only "*", but also "0" to select a whole type.

This functionality should be either removed or documented. The latter can be achieved by effectively reverting [1]. Note that said commit was squashed before merging.

[1] https://github.com/mbalassi/flink/commit/237f07eb113508703c980b14587d66970e7f6251



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)