Skip to content

Conversation

@fsk119
Copy link
Member

@fsk119 fsk119 commented Oct 23, 2025

What is the purpose of the change

Currently, PyFlink supports to convert datetime object without timezone to TIMESTAMP_LTZ, which is different with java behaviour. In java, users can convert instant object to TIMESTAMP_LTZ only. Therefore, I think we should throw an exception to notify users.

Brief change log

  • Adjust LocalZonedTimestampType behaviour to support datetime with tz
  • Fix coder's behaviour: use the datetime's tz to convert the object to milliseconds in encoding phase.
  • Fix coder's behaviour: use the local tz to restore milliseconds to datetime object in decoding phase.

@flinkbot
Copy link
Collaborator

flinkbot commented Oct 23, 2025

CI report:

Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

@fsk119 fsk119 force-pushed the fix-timestamp_ltz branch from 3aa4709 to 106f8b8 Compare October 23, 2025 12:08
@fsk119 fsk119 marked this pull request as ready for review October 24, 2025 07:05
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants