[
https://issues.apache.org/jira/browse/FLINK-32941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Kim updated FLINK-32941:
----------------------------
Description:
When the code below is executed, only the first element of the list is assigned
to the List variable in MyPoJo repeatedly.
{code:java}
case class Item(
id: String,
name: String
)
case class MyPojo(
@DataTypeHist("RAW") items: java.util.List[Item]
)
...
tableEnv
.sqlQuery("select items from table")
.toDataStream(DataTypes.of(classOf[MyPoJo])) {code}
For example, if you have the following list coming in as input,
["a","b","c"]
The value actually stored in MyPojo's list variable is
["a","a","a"]
was:
When the code below is executed, only the first element of the list is assigned
to the List variable in MyPoJo repeatedly.
{code:java}
case class Item(
id: String,
name: String
)
case class MyPojo(
@DataTypeHist("RAW") items: java.util.List[Item]
)
...
tableEnv
.sqlQuery("select items from table")
.toDataStream(DataTypes.of(classOf[MyPoJo])) {code}
For example, if you have the following list coming in as input,
["a","b","c"]
The value actually stored in MyPojo's list variable is
["a","a","a"]
> Table API Bridge `toDataStream(targetDataType)` function not working
> correctly for Java List
> --------------------------------------------------------------------------------------------
>
> Key: FLINK-32941
> URL: https://issues.apache.org/jira/browse/FLINK-32941
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Reporter: Tan Kim
> Priority: Major
> Labels: bridge
>
> When the code below is executed, only the first element of the list is
> assigned to the List variable in MyPoJo repeatedly.
> {code:java}
> case class Item(
> id: String,
> name: String
> )
> case class MyPojo(
> @DataTypeHist("RAW") items: java.util.List[Item]
> )
> ...
> tableEnv
> .sqlQuery("select items from table")
> .toDataStream(DataTypes.of(classOf[MyPoJo])) {code}
>
> For example, if you have the following list coming in as input,
> ["a","b","c"]
> The value actually stored in MyPojo's list variable is
> ["a","a","a"]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
