Caizhi Weng created FLINK-23885:
-----------------------------------
Summary: 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
Reporter: Caizhi Weng
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)
