Robert Metzger created FLINK-6569: ------------------------------------- Summary: flink-table KafkaJsonTableSource example doesn't work Key: FLINK-6569 URL: https://issues.apache.org/jira/browse/FLINK-6569 Project: Flink Issue Type: Bug Components: Documentation, Table API & SQL Affects Versions: 1.3.0 Reporter: Robert Metzger
The code example uses {code} TypeInformation<Row> typeInfo = Types.ROW( new String[] { "id", "name", "score" }, new TypeInformation<?>[] { Types.INT(), Types.STRING(), Types.DOUBLE() } ); {code} the correct way of using it is something like {code} TypeInformation<Row> typeInfo = Types.ROW_NAMED( new String[] { "id", "zip", "date" }, Types.LONG, Types.INT, Types.SQL_DATE); {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)