This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 05a4e9ca154b chore(ci): remove repeated checkout (#17755)
add bd0ae66020ea chore(ci): Hudi-utilities test improvements (#17758)
No new revisions were added by this update.
Summary of changes:
azure-pipelines-20230430.yml | 20 +-
hudi-aws/pom.xml | 5 +
.../client/transaction/TestTransactionManager.java | 2 +-
hudi-tests-common/pom.xml | 5 -
hudi-utilities/pom.xml | 20 +-
.../streamer/HoodieMultiTableStreamer.java | 9 +-
.../callback/TestKafkaCallbackProvider.java | 2 +-
.../deltastreamer/HoodieDeltaStreamerTestBase.java | 58 ++++--
.../deltastreamer/TestHoodieDeltaStreamer.java | 232 ++++++++++-----------
.../TestHoodieDeltaStreamerDAGExecution.java | 2 +
...TestHoodieDeltaStreamerSchemaEvolutionBase.java | 3 +
...estHoodieDeltaStreamerSchemaEvolutionQuick.java | 3 +-
.../utilities/deltastreamer/TestTransformer.java | 1 +
.../multisync/TestMultipleMetaSync.java | 6 +-
.../utilities/sources/BaseTestKafkaSource.java | 20 +-
.../utilities/sources/TestAvroKafkaSource.java | 19 +-
.../hudi/utilities/sources/TestJsonDFSSource.java | 2 +-
.../sources/TestJsonKafkaSourcePostProcessor.java | 2 +-
.../debezium/TestAbstractDebeziumSource.java | 23 +-
.../sources/helpers/TestKafkaOffsetGen.java | 24 ++-
.../hudi/utilities/testutils/KafkaTestUtils.java | 148 +++++++++++++
pom.xml | 6 +
22 files changed, 397 insertions(+), 215 deletions(-)
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/KafkaTestUtils.java
