[FLINK-6569] flink-table KafkaJsonTableSource example doesn't work

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 1.3.0
• Component/s: Documentation, Table SQL / API
• Assignee: Haohui Mai
• Reporter: Robert Metzger
• Created: 12/May/17 13:47
• Updated: 10/Oct/17 22:08
• Resolved: 10/Oct/17 22:08

Description

The code example uses

TypeInformation<Row> typeInfo = Types.ROW(
  new String[] { "id", "name", "score" },
  new TypeInformation<?>[] { Types.INT(), Types.STRING(), Types.DOUBLE() }
);

the correct way of using it is something like

TypeInformation<Row> typeInfo = Types.ROW_NAMED(
                new String[] { "id", "zip", "date" },
                Types.LONG, Types.INT, Types.SQL_DATE);

Issue Links

• links to: GitHub Pull Request #3890