Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3502
Hi @DmytroShkvyra,
as I mentioned earlier, the first thing we should fix in this PR is using
more of Calcite capabilities. Calcite provides a `SubQueryRemoveRule` and
according to the Javadoc this is exaclty what we need in order to properly
support the IN for non-literals.
```
Transform that converts IN, EXISTS and scalar sub-queries into joins.
```
But I'm fine with focusing on literals first, if you like.
In general, creating objects in streaming applications is always very
expensive as they have to be garbage collected which affects latency and
throughput. BigDecimal should be avoided at all times and only be used if it is
really necessary.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
