This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch bot/trino-pin
in repository https://gitbox.apache.org/repos/asf/hudi.git
discard e61e8b05e28f chore(trino): advance trino master pin to d3d4c7c0dfc3
add 9b39f0450787 fix(common): correct incremental fallback reads when a
stale non-write instant precedes the first active commit (#20273)
add fe1c31d385bd fix(hfile): use long cursor offsets in native HFile
reader for files larger than 2GB (#20309)
add 276d120b839a fix(flink): retain files with missing column statistics
(#20295)
add 61dde8631136 fix(flink): make the bucket pruning function serializable
for source V2 (#20318)
add 6bbf798f88d4 fix(spark): render decimal, date and timestamp values in
CDC images (#20305)
add bc78d06bd217 fix(kafka-connect): treat a completed commit as
successful when a post-commit action fails (#20316)
add 9086d9819a5d fix(kafka-connect): retry start commit when the topic
partition lookup fails (#20312)
add b0ea242c8a65 fix(kafka-connect): close AdminClient after fetching
topic partitions (#20303)
new 71f13c5860ec chore(trino): advance trino master pin to 5706548dade9
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e61e8b05e28f)
\
N -- N -- N refs/heads/bot/trino-pin (71f13c5860ec)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../timeline/TestCompletionTimeQueryView.java | 95 +++++++++++++++++
.../hudi/common/table/cdc/HoodieCDCUtils.java | 4 -
.../table/read/IncrementalQueryAnalyzer.java | 21 ++--
.../hudi/common/table/timeline/HoodieTimeline.java | 7 ++
.../versioning/v2/CompletionTimeQueryViewV2.java | 33 +++++-
.../hudi/core/read/BaseHoodieTableFileIndex.java | 21 +++-
.../core/read/BaseHoodieTableFileIndexTest.java | 73 ++++++++++++-
.../apache/hudi/source/prune/ColumnStatsProbe.java | 8 ++
.../hudi/source/prune/PrimaryKeyPruners.java | 4 +-
.../apache/hudi/source/stats/FileStatsIndex.java | 7 +-
.../hudi/source/prune/TestColumnStatsProbe.java | 28 +++++
.../hudi/source/prune/TestPrimaryKeyPruners.java | 17 +++
.../hudi/source/stats/TestColumnStatsIndex.java | 115 +++++++++++++++++++++
.../apache/hudi/table/ITTestHoodieDataSource.java | 40 ++++++-
.../java/org/apache/hudi/io/hfile/HFileCursor.java | 7 +-
.../org/apache/hudi/io/hfile/HFileDataBlock.java | 8 +-
.../org/apache/hudi/io/hfile/HFileReaderImpl.java | 14 +--
.../org/apache/hudi/io/hfile/TestHFileReader.java | 90 ++++++++++++++++
.../transaction/ConnectTransactionCoordinator.java | 2 +-
.../hudi/connect/utils/KafkaConnectUtils.java | 3 +-
.../writers/KafkaConnectTransactionServices.java | 51 +++++++--
.../connect/TestConnectTransactionCoordinator.java | 42 ++++++++
.../hudi/connect/utils/TestKafkaConnectUtils.java | 81 +++++++++++++++
.../TestKafkaConnectTransactionServices.java | 108 ++++++++++++++++++-
.../org/apache/hudi/cdc/CDCFileGroupIterator.scala | 10 +-
.../cdc/InternalRowToJsonStringConverter.scala | 17 ++-
.../cdc/TestInternalRowToJsonStringConverter.scala | 51 ++++++++-
.../TestIncrementalReadWithFullTableScan.scala | 114 +++++++++++++++++++-
.../functional/cdc/TestCDCDataFrameSuite.scala | 56 +++++++++-
pom.xml | 2 +-
30 files changed, 1054 insertions(+), 75 deletions(-)
create mode 100644
hudi-kafka-connect/src/test/java/org/apache/hudi/connect/utils/TestKafkaConnectUtils.java
