Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-21 Thread via GitHub
twalthr merged PR #26019: URL: https://github.com/apache/flink/pull/26019 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-21 Thread via GitHub
twalthr commented on PR #26019: URL: https://github.com/apache/flink/pull/26019#issuecomment-2604167596 @flinkbot run azure -- 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.

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
twalthr commented on PR #26019: URL: https://github.com/apache/flink/pull/26019#issuecomment-2602758856 @flinkbot run azure -- 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.

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
snuyanzin commented on PR #26019: URL: https://github.com/apache/flink/pull/26019#issuecomment-2602446034 fyi: the failure seems to be fixed in later commits https://github.com/apache/flink/commit/1afe645f59fc5239cbe027f67d3c00dc0e66fbc6 rebase might help -- This is an automated me

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
twalthr commented on PR #26019: URL: https://github.com/apache/flink/pull/26019#issuecomment-2602435634 @flinkbot run azure -- 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.

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
snuyanzin commented on code in PR #26019: URL: https://github.com/apache/flink/pull/26019#discussion_r1922300665 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalProcessTableFunction.java: ## @@ -0,0 +1,218

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
twalthr commented on code in PR #26019: URL: https://github.com/apache/flink/pull/26019#discussion_r1922231487 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableFunctionScan.java: ## @@ -0,0 +1,128 @@ +/* Review

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
flinkbot commented on PR #26019: URL: https://github.com/apache/flink/pull/26019#issuecomment-2601882942 ## CI report: * 41a33df93125a357bed41eecbc97cbc04741f539 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
snuyanzin commented on code in PR #26019: URL: https://github.com/apache/flink/pull/26019#discussion_r1921955642 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableFunctionScan.java: ## @@ -0,0 +1,128 @@ +/* Revi

Re: [PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-20 Thread via GitHub
snuyanzin commented on code in PR #26019: URL: https://github.com/apache/flink/pull/26019#discussion_r1921955642 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableFunctionScan.java: ## @@ -0,0 +1,128 @@ +/* Revi

[PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-19 Thread via GitHub
twalthr opened a new pull request, #26019: URL: https://github.com/apache/flink/pull/26019 ## What is the purpose of the change This implements a first skeleton for integrating PTFs into the planner. The PR prepares the code base for implementing a corresponding StreamExecNode.