Re: Issue with FilterableTableSource and the logical optimizer rules

t; Rong > > [1] https://issues.apache.org/jira/browse/FLINK-12399 > > > On Mon, Aug 19, 2019 at 8:56 AM Itamar Ravid wrote: > > > Hi, I’m facing a strange issue with Flink 1.8.1. I’ve implemented a > > > StreamTableSource that implements FilterableTableSource and > > &

Issue with FilterableTableSource and the logical optimizer rules

Hi, I’m facing a strange issue with Flink 1.8.1. I’ve implemented a StreamTableSource that implements FilterableTableSource and ProjectableTableSource. However, I’m seeing that during the logical plan optimization (TableEnvironment.scala:288), the applyPredicates method is called but the result