Re: [DISCUSS] FLIP-356: Support Nested Fields Filter Pushdown

Thanks for all the feedback and discussion everyone. Looks like we have reached a consensus here. Just to summarize: 1. Introduce a new *ReferenceExpression* (or *BaseReferenceExpression*) abstract class which will be extended by both *FieldReferenceExpression* and

[jira] [Created] (FLINK-32969) IfCallGen Bug

Lyn Zhang created FLINK-32969: - Summary: IfCallGen Bug Key: FLINK-32969 URL: https://issues.apache.org/jira/browse/FLINK-32969 Project: Flink Issue Type: Bug Reporter: Lyn Zhang

[jira] [Created] (FLINK-32968) Update doc for customized catalog listener

Fang Yong created FLINK-32968: - Summary: Update doc for customized catalog listener Key: FLINK-32968 URL: https://issues.apache.org/jira/browse/FLINK-32968 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

Hi Xuannan, Thanks for the proposal. +1 for me. There is one tiny thing that I am not sure if I understand it correctly. Since there will be many different WatermarkStrategies and different WatermarkGenerators. Could you please update the FLIP and add the description of how the watermark lag is

[jira] [Created] (FLINK-32967) [JUnit5 Migration] Module: flink-table-planner

Jiabao Sun created FLINK-32967: -- Summary: [JUnit5 Migration] Module: flink-table-planner Key: FLINK-32967 URL: https://issues.apache.org/jira/browse/FLINK-32967 Project: Flink Issue Type:

[jira] [Created] (FLINK-32966) [JUnit5 Migration] Module: flink-table-planner

Jiabao Sun created FLINK-32966: -- Summary: [JUnit5 Migration] Module: flink-table-planner Key: FLINK-32966 URL: https://issues.apache.org/jira/browse/FLINK-32966 Project: Flink Issue Type: