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
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
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