This is an automated email from the ASF dual-hosted git repository. michaelsmith pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/impala.git
commit 963de82e53767075caf7ee16ca9fd3caafc53c18 Author: Sai Hemanth Gantasala <[email protected]> AuthorDate: Wed Mar 15 19:46:57 2023 -0700 IMPALA-11822: (Addendum) Optimize the Refresh/Invalidate event processing by skipping unnecessary events IMPALA-11822 introduced a new argument 'lastRefreshEventId' to the HdfsPartition constructor and this is causing Hive builds to fail. This addendum patch addresses this issue by keeping the old constructor in the HdfsPartition class and call the new constructor with -1L as default value for 'lastRefreshEventId'. Testing: Verified that the Hive builds are passing with this patch. Change-Id: I803c13b58e3de047c12f75a584232819c7dc74c1 Reviewed-on: http://gerrit.cloudera.org:8080/19624 Reviewed-by: Impala Public Jenkins <[email protected]> Tested-by: Impala Public Jenkins <[email protected]> --- .../java/org/apache/impala/catalog/HdfsPartition.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java b/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java index bbd4bb129..855637982 100644 --- a/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java +++ b/fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java @@ -773,6 +773,25 @@ public class HdfsPartition extends CatalogObjectImpl /*lastRefreshEventId*/-1L); } + protected HdfsPartition(HdfsTable table, long id, long prevId, String partName, + List<LiteralExpr> partitionKeyValues, HdfsStorageDescriptor fileFormatDescriptor, + @Nonnull ImmutableList<byte[]> encodedFileDescriptors, + ImmutableList<byte[]> encodedInsertFileDescriptors, + ImmutableList<byte[]> encodedDeleteFileDescriptors, + HdfsPartitionLocationCompressor.Location location, + boolean isMarkedCached, TAccessLevel accessLevel, Map<String, String> hmsParameters, + CachedHmsPartitionDescriptor cachedMsPartitionDescriptor, + byte[] partitionStats, boolean hasIncrementalStats, long numRows, long writeId, + InFlightEvents inFlightEvents, long createEventId, long lastCompactionId) { + this(table, partitionIdCounter_.getAndIncrement(), prevId, partName, + partitionKeyValues, fileFormatDescriptor, encodedFileDescriptors, + encodedInsertFileDescriptors, encodedDeleteFileDescriptors, location, + isMarkedCached, accessLevel, hmsParameters, cachedMsPartitionDescriptor, + partitionStats, hasIncrementalStats, numRows, writeId, + inFlightEvents, /*createEventId=*/-1L, /*lastCompactionId*/-1L, + /*lastRefreshEventId*/-1L); + } + protected HdfsPartition(HdfsTable table, long id, long prevId, String partName, List<LiteralExpr> partitionKeyValues, HdfsStorageDescriptor fileFormatDescriptor, @Nonnull ImmutableList<byte[]> encodedFileDescriptors,
