[jira] [Created] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[Shang Yuanchun (Jira)]

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)