Good day to everyone. Have anyone had an issue when a Flink query optimizer just drops WHERE clause from a statement and rewrite results instead of filtering them? It happens with Lookup table from Postgres, but works as expected for versioned table from Kafka. The issue is visible in an image with comparing two bottom screen splits looking at tabs named objective_explode and objective_filter. Up to explode everything was fine: First lookup by primary key, unnesting, and second lookup properly took appropriate value we could see in column c49 in objective_explode. And then I just did WHERE clause and as you can see column c49 row 2 in objective_filter tab hat not been filtered out, instead it got 'psm' value. Compare with column c53 where 'count' value stays and indicates that psm value is not a valid one for that record. Technical details are in a thread. The query to filter data from explode view.

create temporary view cxq_internal_service_level_indicator_psm_5sec_over_1hour_objective_filter
as
select
    *
from
    cxq_internal_service_level_indicator_psm_5sec_over_1hour_objective_explode slo
where
      slo.measurement_type = 'psm'
  and slo.measurement_flavor = '5s'
  and slo.metric_interval_unit = 'hour'
  and slo.metric_interval_duration = 1
  and slo.nested_type is null;