[FLINK-32941] Table API Bridge `toDataStream(targetDataType)` function not working correctly for Java List

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / API
• Labels: auto-deprioritized-critical bridge
• Assignee: Unassigned
• Reporter: Tan Kim
• Created: 23/Aug/23 01:10
• Updated: 14/Sep/23 22:35

Description

When the code below is executed, only the first element of the list is assigned to the List variable in MyPoJo repeatedly.

case class Item(
  name: String
)
case class MyPojo(
  @DataTypeHist("RAW") items: java.util.List[Item]
)

...

tableEnv
  .sqlQuery("select items from table")
  .toDataStream(DataTypes.of(classOf[MyPoJo])) 

 

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"]