[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011243#comment-16011243 ]
ASF GitHub Bot commented on FLINK-6569: --------------------------------------- Github user haohui commented on the issue: https://github.com/apache/flink/pull/3890 My understanding is that the snippet should only depend on the Java version of the API (`ROW_NAMED` in flink-core) instead of the one written in Scala that resides in `flink-table`. Correct? > 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 > Assignee: Haohui Mai > Fix For: 1.3.0 > > > 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)