flink中的Map显示为通用?

kwvwclae  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(252)

我在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.

有什么办法解决这个问题吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题