This is an automated email from the ASF dual-hosted git repository.
codope pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 0fda680bf2c [HUDI-6478] Deduce op as upsert for INSERT INTO (#9665)
add fe71659a672 [HUDI-6825] Use UTF_8 to encode String to byte array in
all places (#9634)
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/cli/commands/TableCommand.java | 3 ++-
.../cli/integ/ITTestHDFSParquetImportCommand.java | 10 ++++---
.../HoodieTestCommitMetadataGenerator.java | 4 +--
.../hudi/client/BaseHoodieTableServiceClient.java | 4 +--
.../apache/hudi/client/BaseHoodieWriteClient.java | 6 ++---
.../hudi/client/timeline/LSMTimelineWriter.java | 7 ++---
.../utils/LegacyArchivedMetaEntryReader.java | 5 ++--
.../index/bucket/ConsistentBucketIndexUtils.java | 3 ++-
.../action/commit/BaseCommitActionExecutor.java | 4 +--
.../hudi/table/action/compact/CompactHelpers.java | 7 ++---
.../org/apache/hudi/HoodieTestCommitGenerator.java | 4 +--
.../timeline/TestCompletionTimeQueryView.java | 3 ++-
.../io/storage/TestHoodieHFileReaderWriter.java | 25 ++++++++---------
.../hudi/client/HoodieFlinkTableServiceClient.java | 5 ++--
.../row/HoodieRowDataParquetWriteSupport.java | 4 +--
.../commit/BaseFlinkCommitActionExecutor.java | 5 ++--
.../commit/BaseJavaCommitActionExecutor.java | 5 ++--
.../testutils/HoodieJavaClientTestHarness.java | 3 ++-
.../client/utils/SparkInternalSchemaConverter.java | 14 +++++-----
.../SparkBootstrapCommitActionExecutor.java | 4 +--
.../commit/BaseSparkCommitActionExecutor.java | 6 ++---
.../apache/hudi/io/TestHoodieTimelineArchiver.java | 8 +++---
.../table/action/commit/TestUpsertPartitioner.java | 14 +++++-----
.../table/functional/TestCleanPlanExecutor.java | 4 +--
.../hudi/testutils/HoodieCleanerTestBase.java | 4 +--
.../hudi/testutils/HoodieClientTestUtils.java | 3 ++-
.../apache/hudi/avro/GenericAvroSerializer.java | 6 +++--
.../java/org/apache/hudi/avro/HoodieAvroUtils.java | 4 +--
.../apache/hudi/avro/HoodieAvroWriteSupport.java | 4 +--
.../apache/hudi/avro/MercifulJsonConverter.java | 4 ++-
.../org/apache/hudi/common/HoodieJsonPayload.java | 4 ++-
.../bloom/HoodieDynamicBoundedBloomFilter.java | 7 ++---
.../hudi/common/bloom/SimpleBloomFilter.java | 9 ++++---
.../bootstrap/index/HFileBootstrapIndex.java | 4 ++-
.../model/HoodieConsistentHashingMetadata.java | 6 +++--
.../hudi/common/model/HoodiePartitionMetadata.java | 4 ++-
.../hudi/common/table/HoodieTableConfig.java | 4 +--
.../table/log/block/HoodieAvroDataBlock.java | 5 ++--
.../table/log/block/HoodieHFileDataBlock.java | 5 ++--
.../common/table/log/block/HoodieLogBlock.java | 3 ++-
.../table/timeline/HoodieDefaultTimeline.java | 3 ++-
.../org/apache/hudi/common/util/AvroOrcUtils.java | 8 +++---
.../apache/hudi/common/util/Base64CodecUtil.java | 4 ++-
.../org/apache/hudi/common/util/BinaryUtil.java | 5 ++--
.../org/apache/hudi/common/util/NumericUtils.java | 5 ++--
.../org/apache/hudi/common/util/StringUtils.java | 5 ++++
.../hudi/common/util/collection/RocksDBDAO.java | 23 +++++++++-------
.../org/apache/hudi/common/util/hash/HashID.java | 7 ++---
.../io/FileBasedInternalSchemaStorageManager.java | 3 ++-
.../hudi/io/storage/HoodieAvroHFileReader.java | 21 ++++++++-------
.../hudi/io/storage/HoodieAvroHFileWriter.java | 26 +++++++++---------
.../hudi/io/storage/HoodieAvroOrcWriter.java | 26 +++++++++---------
.../hudi/metadata/HoodieTableMetadataUtil.java | 5 ++--
.../org/apache/hudi/avro/TestHoodieAvroUtils.java | 3 ++-
.../common/fs/TestHoodieWrapperFileSystem.java | 6 ++---
.../inline/TestInLineFileSystemHFileInLining.java | 3 ++-
.../common/functional/TestHoodieLogFormat.java | 15 ++++++-----
.../debezium/TestPostgresDebeziumAvroPayload.java | 9 ++++---
.../common/table/TestHoodieTableMetaClient.java | 9 ++++---
.../hudi/common/table/TestTimelineUtils.java | 6 ++---
.../table/timeline/TestHoodieActiveTimeline.java | 4 +--
.../view/TestHoodieTableFSViewWithClustering.java | 4 +--
.../table/view/TestHoodieTableFileSystemView.java | 18 ++++++-------
.../table/view/TestIncrementalFSViewSync.java | 10 +++----
.../hudi/common/testutils/FileCreateUtils.java | 12 ++++-----
.../common/testutils/HoodieTestDataGenerator.java | 8 +++---
.../hudi/common/testutils/RawTripTestPayload.java | 3 ++-
.../minicluster/ZookeeperTestService.java | 6 +++--
.../hudi/common/util/TestBase64CodecUtil.java | 4 +--
.../apache/hudi/common/util/TestFileIOUtils.java | 10 +++----
.../hudi/common/util/TestOrcReaderIterator.java | 6 ++---
.../apache/hudi/common/util/TestStringUtils.java | 7 ++---
.../apache/hudi/common/util/hash/TestHashID.java | 4 +--
.../apache/hudi/schema/SchemaRegistryProvider.java | 4 +--
.../hudi/util/JsonDeserializationFunction.java | 4 +--
.../apache/hudi/util/StringToRowDataConverter.java | 5 ++--
.../hudi/source/TestIncrementalInputSplits.java | 6 ++---
.../org/apache/hudi/util/TestExpressionUtils.java | 4 +--
.../test/java/org/apache/hudi/utils/TestUtils.java | 5 ++--
.../table/format/cow/ParquetSplitReaderUtil.java | 4 +--
.../table/format/cow/ParquetSplitReaderUtil.java | 4 +--
.../table/format/cow/ParquetSplitReaderUtil.java | 4 +--
.../table/format/cow/ParquetSplitReaderUtil.java | 4 +--
.../table/format/cow/ParquetSplitReaderUtil.java | 4 +--
.../org/apache/hudi/hadoop/InputSplitUtils.java | 4 ++-
.../hudi/hadoop/TestHoodieHFileInputFormat.java | 4 +--
.../hudi/hadoop/TestHoodieParquetInputFormat.java | 31 +++++++++++-----------
.../realtime/TestHoodieRealtimeFileSplit.java | 18 ++++++-------
.../realtime/TestHoodieRealtimeRecordReader.java | 6 ++---
.../hudi/connect/utils/KafkaConnectUtils.java | 5 ++--
.../org/apache/hudi/helper/MockKafkaConnect.java | 6 +++--
.../hudi/writers/TestAbstractConnectWriter.java | 3 ++-
.../AlterHoodieTableAddColumnsCommand.scala | 4 +--
.../spark/hudi/benchmark/HoodieBenchmarkBase.scala | 7 ++---
.../benchmark/LSMTimelineReadBenchmark.scala | 3 ++-
.../procedure/TestHdfsParquetImportProcedure.scala | 5 ++--
.../spark/sql/hudi/command/AlterTableCommand.scala | 4 +--
.../hudi/hive/testutils/HiveTestCluster.java | 4 +--
.../apache/hudi/hive/testutils/HiveTestUtil.java | 14 +++++-----
.../utilities/HoodieMetadataTableValidator.java | 5 ++--
.../hudi/utilities/perf/TimelineServerPerf.java | 6 +++--
.../utilities/schema/SchemaRegistryProvider.java | 4 +--
.../sources/helpers/ProtoConversionUtil.java | 4 ++-
.../deltastreamer/HoodieDeltaStreamerTestBase.java | 4 +--
.../functional/TestHDFSParquetImporter.java | 5 ++--
.../schema/TestSchemaRegistryProvider.java | 4 +--
.../utilities/sources/TestGcsEventsSource.java | 16 ++++++-----
.../utilities/sources/TestProtoKafkaSource.java | 5 ++--
.../sources/helpers/TestProtoConversionUtil.java | 9 ++++---
109 files changed, 416 insertions(+), 333 deletions(-)
