Hi, 非常欢迎你一起参与社区的建设中来。 社区有一套完整的贡献流程,大体可以参照文档[1]。
总的来说可以细分为: 1、发现问题,并在jira[2]中提出一个issue 2、提一个pr并在pr中写明相关的issue号码+模块名+简单描述,具体可以参考下其他的pr来写 3、热心的同学会帮你review的,你也可以在你新建的issue下面ping我下(xuyang) [1] https://flink.apache.org/contributing/how-to-contribute.html [2] https://issues.apache.org/jira/projects/FLINK/issues/FLINK-27084?filter=allopenissues -- Best! Xuyang 在 2022-06-07 18:08:10,"朱育锋" <comeonyf...@163.com> 写道: >Hi > >很抱歉这么晚回复 > >1. Hi >Xuyang老师,确实如你所说,调用applyFilters方法之后,又调用了copy方法生成了新的JdbcDynamicTableSource对象,在新的JdbcDynamicTableSource对象中再次调用了getScanRuntimeProvider方法。现在已经成功实现了谓词下推,十分感谢 >2. Hi Shengkai老师,我十分愿意贡献到社区,不过我之前从未参与过GitHub开源项目,这对我既是机会又是挑战,我愿意挑战下自己。 >为此,我通读了一遍Flink官网的贡献指南,当我阅读到这一节时[1],我点击了文本[2]上的链接,显示"The requested URL was not >found on this >server",发现是md文档中链接的URL拼写错误造成的。我提了一个hotfix[3],正好借助这个PR熟悉下贡献流程,辛苦老师帮忙Review下 > >[1] >https://flink.apache.org/contributing/code-style-and-quality-common.html#nullability-of-the-mutable-parts >[2] "usage of Java Optional" >https://flink.apache.org/contributing/code-style-and-quality-java.md#java-optional >[3] https://github.com/apache/flink-web/pull/544 > >Best regards >YuFeng > >> 2022年6月2日 10:28,Shengkai Fang <fskm...@gmail.com> 写道: >> >> Hi. >> >> 我记得 Jdbc Connector 实现了 ProjectionPushDown。你可以参考着实现。 >> >> xuyang 老师说的对,getScanRuntimeProvider 发生在 push down >> 之后。应该不会有你说的问题。另外,可以考虑贡献到社区[1],我们也可以帮忙一起 review 下,帮忙解决你的问题? >> >> Best, >> Shengkai >> >> [1] https://issues.apache.org/jira/browse/FLINK-19651 >> >> Xuyang <xyzhong...@163.com> 于2022年6月1日周三 23:47写道: >> >>> >>> Hi,在SQL优化的末尾,StreamPhysicalTableSourceScan转化为StreamExecTableSourceScan的过程中[1],会执行一次getScanRuntimeProvider,此时的getScanRuntimeProvider一定是在applyFilters方法之后触发的。 >>> >>> >>> >>> >>> 你可以尝试将filterFields记录在JdbcDynamicTableSource >>> 这个类中,如果该值为空,则getScanRuntimeProvider >>> 时无需拼接(在applyFilters执行之前一定是空的);当该值不为空的时候,在getScanRuntimeProvider >>> 进行拼接(最后一次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/common/CommonExecTableSourceScan.java#L83 >>> >>> >>> >>> >>> -- >>> >>> Best! >>> Xuyang >>> >>> >>> >>> >>> >>> 在 2022-06-01 20:03:58,"朱育锋" <comeonyf...@163.com> 写道: >>> >>> Hi,在SQL优化的末尾,StreamPhysicalTableSourceScan转化为StreamExecTableSourceScan的过程中[1],会执行一次getScanRuntimeProvider,此时的getScanRuntimeProvider一定是在applyFilters方法之后触发的。<br/><br/>你可以尝试将filterFields记录在JdbcDynamicTableSource >>> 这个类中,如果该值为空,则getScanRuntimeProvider >>> 时无需拼接(在applyFilters执行之前一定是空的);当该值不为空的时候,在getScanRuntimeProvider >>> 进行拼接(最后一次physical node转exec node时,一定执行过applyFilters方法)。<br/><br/>[1] >>> https://github.com/apache/flink/blob/98997ea37ba08eae0f9aa6dd34823238097d8e0d/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java#L83