Re: Issue with FilterableTableSource and the logical optimizer rules

2019-08-19 Thread Itamar Ravid
Hi Rong, thanks for the hint - that solved the issue. On 20 Aug 2019, 0:06 +0300, Rong Rong , wrote: > Hi Itamar, > > The problem you described sounds similar to this ticket[1]. > Can you try to see if following the solution listed resolves your issue? > > -- > Rong > > [1] https://issues.apache.or

Re: Issue with FilterableTableSource and the logical optimizer rules

2019-08-19 Thread Rong Rong
Hi Itamar, The problem you described sounds similar to this ticket[1]. Can you try to see if following the solution listed resolves your issue? -- 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 wi

Issue with FilterableTableSource and the logical optimizer rules

2019-08-19 Thread Itamar Ravid
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