[GitHub] [flink] lindong28 commented on a diff in pull request #23021: [FLINK-32603] Avoid consuming twice when two pipelines have the same table source

lindong28 commented on code in PR #23021: URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java: ## @@ -103,56 +106,63 @@ protec

[GitHub] [flink] lindong28 commented on a diff in pull request #23021: [FLINK-32603] Avoid consuming twice when two pipelines have the same table source

lindong28 commented on code in PR #23021: URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java: ## @@ -103,56 +106,63 @@ protec