Hi to all, I was trying to use a view of my Postgres database through the PostgresCatalog but at the moment it seems that the current implementation ignores views. Probably this is caused by the fact that there's no way to avoid INSERT statements in Flink. However, the thrown error is somehow misleading because the PostgresCatalog.getTable() throws a TableNotExistException whose errore message is
private static final String MSG = "Table (or view) %s does not exist in Catalog %s."; Maybe the thrown exception could be more helpful and could report that views are not supported by this catalog implementation. What do you think? Best, Flavio
