[jira] [Updated] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info

["Caizhi Weng (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-23885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Caizhi Weng updated FLINK-23885:
--------------------------------
    Component/s: API / DataStream

> DataStream<Integer>#map(int value -> row value).getType() produces a generic type info of row instead of row type info
> ----------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-23885
>                 URL: https://issues.apache.org/jira/browse/FLINK-23885
>             Project: Flink
>          Issue Type: Bug
>          Components: API / DataStream
>    Affects Versions: 1.14.0
>            Reporter: Caizhi Weng
>            Priority: Major
>
> This is reported by the user in the [mailing list|https://lists.apache.org/thread.html/r975eb2a638a120d7c739fd177bf8a16283585fd0457ba8fd4bfce65a%40%3Cuser.flink.apache.org%3E].
> Run the following test to reproduce this problem.
> {code:java}
> @Test
> public void myTest() {
>     StreamExecutionEnvironment flinkEnv = StreamExecutionEnvironment.getExecutionEnvironment();
>     flinkEnv.setRuntimeMode(RuntimeExecutionMode.STREAMING);
>     DataStream<Integer> integers = flinkEnv.fromElements(12, 5);
>     DataStream<Row> rows1 = integers.map(i -> Row.of("Name" + i, i));
>     DataStream<Row> rows2 = flinkEnv.fromElements(Row.of("Name12", 12), Row.of("Name5", 5));
>     System.out.println(rows1.getType()); // GenericType<org.apache.flink.types.Row>
>     System.out.println(rows2.getType()); // Row(f0: String, f1: Integer)
> }
> {code}
> As shown in the test, {{rows1.getType()}} produces a generic type of row instead of row type.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)