YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-814064673
OK, I figured it out. Since I abstracted away `createTableScanAfterPushdown` to the base class, I always returned `FlinkLogicalTableScan.create`. This can't happen since the inherting classes are in different phases, one in logical optimization phase and one in the logical rewrite phase. Thus, I need a LogicalTableScan for the former and a FlinkLogicalTableSourceScan for the latter. Pushed the fix. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
