This is an automated email from the ASF dual-hosted git repository.
voonhous pushed a change to branch release-1.2.1
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 47241bf647d7 test(spark): drop the adapter-dependent String case from
convertValueToEngineType
add 3bd76ead3e3f perf(flink): use a shared work-stealing split pool for
Source V2 bounded reads (#19520)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hudi/source/HoodieSource.java | 23 +-
.../source/split/GlobalHoodieSplitProvider.java | 134 ++++++
.../TestHoodieSourceEnumeratorRouting.java | 472 +++++++++++++++++++++
.../TestHoodieStaticSplitEnumerator.java | 86 ++++
.../split/TestGlobalHoodieSplitProvider.java | 298 +++++++++++++
5 files changed, 1007 insertions(+), 6 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/GlobalHoodieSplitProvider.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieSourceEnumeratorRouting.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestGlobalHoodieSplitProvider.java
