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(
}
private static class MultiStateProcessTableFunction extends
ProcessTableFunction<Integer> {
- public void eval(@StateHint MyFirstState s1, @StateHint MySecondState
s2, Integer i) {}
+ public void eval(
+ @StateHint(ttl = "2 days") MyFirstState s1,
+ @StateHint(ttl = "0") MySecondState s2,
+ Integer i) {}
Review Comment:
No I think the backend supports only milliseconds. Similar to our timer
services as well. This rather sounds like an edge case. Also not sure what
happens if you set the global retention time `table.exec.state.ttl` this way,
we simply call `.toMillis()`.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
