-
Notifications
You must be signed in to change notification settings - Fork 2.2k
[Improve][File-Connector] Support write fixed/timestamp as int96 of parquet #6971
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
Conversation
bfeb060 to
c8dd70f
Compare
| HadoopInputFile.fromPath(filePath, configuration)); | ||
| int fieldsCount = seaTunnelRowType.getTotalFields(); | ||
| GenericData dataModel = new GenericData(); | ||
| dataModel.addLogicalTypeConversion(new Conversions.DecimalConversion()); |
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.
Why delete this? This will cause abnormal data to be read out.
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.
Thanks, this was a mistake.
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.
reverted
TyrantLucifer
left a comment
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.
c8dd70f to
d99e48e
Compare
fae64ec to
c11f51a
Compare
c11f51a to
e4affb9
Compare
|
cc @Hisoka-X @TyrantLucifer @wuchunfu ci is passed |


Purpose of this pull request
[File-Connector] Support write fixed/timestamp as int96 of parquet
Does this PR introduce any user-facing change?
Add new config items of sink
How was this patch tested?
Added
Check list
New License Guide
release-note.