Tan Kim created FLINK-32941:
-------------------------------
Summary: 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
Reporter: Tan Kim
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)
