我在flink v 1.4.2的pojo中有一个hashmap,例如:
class CustomObj{
public Map<String, String> custTable = new HashMap<>();
//getter and setter
}
运行程序.java
当我这么做的时候
System.out.println(TypeInformation.of(CustomObj.class));
我得到:
PojoType<CustomObj, fields = [custTable: GenericType<java.util.Map>]>
现在的问题是为什么我要把 DataSteam<CustomObj>
并运行sql查询,例如 SELECT * FROM tableName WHERE custTable['key'] = 'val'
,它给了我一个例外:
org.apache.flink.table.api.TableException: Generic ANY types must have a common type information.
有什么办法解决这个问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!