Hello Everyone
在阅读ProcessMemoryUtils类的代码时,我怀疑sanityCheckTotalProcessMemory方法[1]中的主体逻辑永远都不会执行:
1.
在deriveJvmMetaspaceAndOverheadFromTotalFlinkMemory方法中,判断了是否显式配置了TotalProcessMemory[2]
2.
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
Hello Everyone
1. 我的目的是:使Flink Jdbc Connector支持谓词下推
2. 实现过程/背景:
我修改了Flink Jdbc Connector的代码,使 JdbcDynamicTableSource 类实现了
SupportsFilterPushDown 接口。
在SupportsFilterPushDown.applyFilters(List filters)
方法中我解析了Expression并转换成了类似下面的过滤条件