rkwagner commented on issue #13233:
URL: https://github.com/apache/hudi/issues/13233#issuecomment-2839460829
I think I've identified the source.
There is a class in Hudi called Type.java. It has no concept in Timestamp
of millis or micros,
so all timestamps are always in micros if they pass through this class by
way of the AvroInternalSchemaConverter,
which is called in HoodieSchemaUtils.deduceWriterSchema if latestTableSchema
is undefined (it always will be with a brand new Table),
further called in StreamSync.getDeducedSchemaProvider,
called in fetchNextBatchFromSource,
called in streamFromSource,
called in sync
which is the main function used by DeltaStreamers.
--
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]
