[
https://issues.apache.org/jira/browse/FLINK-32832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753064#comment-17753064
]
yong yang commented on FLINK-32832:
-----------------------------------
不兼容 我使用 java Integer就可以,这个我理解. 但是为什么第一个int字段就不需要Interger.
而且 flink int对应 sql int not null, flink integer 对应sql中 int. 这块代码看,没有体现出来.
> Row对象不兼容scala int
> -----------------
>
> Key: FLINK-32832
> URL: https://issues.apache.org/jira/browse/FLINK-32832
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.17.1
> Environment: flink1.17 macos m2芯片
> Reporter: yong yang
> Priority: Minor
>
> val table = tEnv.fromValues(
> DataTypes.ROW(
> DataTypes.FIELD("id", DataTypes.INT().notNull())
> , DataTypes.FIELD("name2", DataTypes.INT().notNull())
> ),
> row(1, Integer.valueOf(11)) // 离谱的是 第一个int可以使scala
> int,后面的int就必须是java.lang.Integer
> )
> table.execute().print(){*}{*}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
