Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-11 Thread via GitHub
twalthr merged PR #26133: URL: https://github.com/apache/flink/pull/26133 -- 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-37219][table] Support value state in PTFs [flink]

2025-02-11 Thread via GitHub
twalthr commented on code in PR #26133: URL: https://github.com/apache/flink/pull/26133#discussion_r1950760130 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java: ## @@ -2277,7 +2288,10 @@ public void eval(

Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-11 Thread via GitHub
twalthr commented on code in PR #26133: URL: https://github.com/apache/flink/pull/26133#discussion_r1950760130 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java: ## @@ -2277,7 +2288,10 @@ public void eval(

Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-10 Thread via GitHub
snuyanzin commented on code in PR #26133: URL: https://github.com/apache/flink/pull/26133#discussion_r1950034192 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java: ## @@ -2277,7 +2288,10 @@ public void eval(

Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-10 Thread via GitHub
snuyanzin commented on code in PR #26133: URL: https://github.com/apache/flink/pull/26133#discussion_r1950014142 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/StateHint.java: ## @@ -70,4 +70,25 @@ * or provide hints for the reflection-ba

Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-10 Thread via GitHub
flinkbot commented on PR #26133: URL: https://github.com/apache/flink/pull/26133#issuecomment-2647955222 ## CI report: * 4101a0b2c5ad908fddf380bda6c80b355c5a1d78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-10 Thread via GitHub
twalthr opened a new pull request, #26133: URL: https://github.com/apache/flink/pull/26133 ## What is the purpose of the change This adds support for value state and thus enables stateful PTFs. For each function call: - the state is read from Flink - converted into exter