我有关于Flink数据流的查询。我有一个用户定义对象的数据流。我必须遍历这个数据流，提取值并为tableenvironment建立一个查询。

DataStream ds1 = ...

tenv.registerDatastream("Messages",ds1 ,.......)

DataStream ds2 = mapFunction .....
    map(MsgObj){
    String qry = Select * from Messages where eventName = MsgObj.name
    Table tname = tenv.sqlQuery(qry) /////This line is giving serialization exception
    }