-
Notifications
You must be signed in to change notification settings - Fork 1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[core][bug] Fix the incorrect partition key format generated from the DATE type #853
Conversation
d953639
to
fe9fc1d
Compare
Kudos, SonarCloud Quality Gate passed! 0 Bugs No Coverage information |
String partitionValue; | ||
|
||
if (Objects.nonNull(field)) { | ||
if (fieldTypes.get(i).is(DataTypeRoot.DATE)) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
also check Time Type
fe9fc1d
to
b4d5b12
Compare
… DATE type and TIME type.
b4d5b12
to
4872ad1
Compare
I've thought about this fix, maybe we can make it more thorough. Like But this will bring more serious issues, incompatibility, and we may need an option or an old class to fall back to the old path when we cannot find it. This is complicated. Is this problem serious now? Can we keep it this way for now? |
I think it's a very user experience affecting issue. I think the current addition of support for DATE type partitioning is sufficient. For the compatibility issue, it will be easy to solve if we can get the version information of paimon. For example, we can determine how to format DATE type partitions based on the version number. I think there are probably few users who use it for the strange performance of the current version of the DATE type partition. |
@yuanoOo, the partition key format is user-defined that the format like |
I think this issue need to fix. For example, we develop a paimon connector of seatunnel which use java api of paimon also has the same problem. |
fix issue: #773
(Please specify the module before the PR name: [core] ... or [flink] ...)
Purpose
(What is the purpose of the change, or the associated issue)
Tests
(List UT and IT cases to verify this change)
API and Format
(Does this change affect API or storage format)
Documentation
(Does this change introduce a new feature)