[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29648.
--------------------------------
Resolution: Fixed
Merged into master via ef0489b5131d03112d8a4ef11962a2d1ba6a9f54
Merged into release-1.16 via 59a276b38813a66f9ad80ed81b3dfcfe26decb7a
> "LocalDateTime not supported" error when retrieving Java TypeInformation from
> PyFlink
> -------------------------------------------------------------------------------------
>
> Key: FLINK-29648
> URL: https://issues.apache.org/jira/browse/FLINK-29648
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.16.0
> Reporter: Juntao Hu
> Assignee: Juntao Hu
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.16.0
>
>
> The following code raises "TypeError: The java type info: LocalDateTime is
> not supported in PyFlink currently.":
> {code:java}
> t_env.to_data_stream(t).key_by(...){code}
> However, this works:
> {code:java}
> t_env.to_data_stream(t).map(lambda r: r).key_by(...){code}
> Although we add Python coders for LocalTimeTypeInfo in 1.16, there's no
> corresponding typeinfo at Python side. So it works when a user immediately
> does processing after to_data_stream since date/time data has already been
> converted to Python object, but when key_by tries to retrieve typeinfo from
> Java TypeInformation, it fails.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
