This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from b2057b356ca [HUDI-8378] Fix Avro schema deserializer failing with
schema evolution (#12111)
add 6edf2094c4d [HUDI-8955] Resolve Kafka beginning offsets with retention
to prevent OffsetOutOfRange exception (#12762)
No new revisions were added by this update.
Summary of changes:
...DefaultSizeEstimator.java => LogicalClock.java} | 16 +-
.../{VisibleForTesting.java => SystemClock.java} | 14 +-
.../apache/hudi/common/util/TestSystemClock.java | 34 +--
hudi-tests-common/pom.xml | 5 +
.../hudi/utilities/config/KafkaSourceConfig.java | 10 +
.../utilities/sources/helpers/KafkaOffsetGen.java | 130 ++++++++++-
.../sources/helpers/TestKafkaOffsetGen.java | 260 ++++++++++++++++++++-
7 files changed, 439 insertions(+), 30 deletions(-)
copy
hudi-common/src/main/java/org/apache/hudi/common/util/{DefaultSizeEstimator.java
=> LogicalClock.java} (70%)
copy
hudi-common/src/main/java/org/apache/hudi/common/util/{VisibleForTesting.java
=> SystemClock.java} (77%)
copy hudi-cli/src/test/java/org/apache/hudi/cli/TestSparkUtil.java =>
hudi-common/src/test/java/org/apache/hudi/common/util/TestSystemClock.java (55%)
