怀疑源码中的一个方法是never reached code

Hello Everyone 在阅读ProcessMemoryUtils类的代码时，我怀疑sanityCheckTotalProcessMemory方法[1]中的主体逻辑永远都不会执行： 1. 在deriveJvmMetaspaceAndOverheadFromTotalFlinkMemory方法中，判断了是否显式配置了TotalProcessMemory[2] 2.

Re: 实现SupportsFilterPushDown接口过程中遇到的问题

vider >> 进行拼接（最后一次physical node转exec node时，一定执行过applyFilters方法）。 >> >> >> >> >> [1] >> https://github.com/apache/flink/blob/98997ea37ba08eae0f9aa6dd34823238097d8e0d/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec

实现SupportsFilterPushDown接口过程中遇到的问题

Hello Everyone 1. 我的目的是：使Flink Jdbc Connector支持谓词下推 2. 实现过程/背景： 我修改了Flink Jdbc Connector的代码，使 JdbcDynamicTableSource 类实现了 SupportsFilterPushDown 接口。 在SupportsFilterPushDown.applyFilters(List filters) 方法中我解析了Expression并转换成了类似下面的过滤条件