Skip to content

Commit bc5ce85

Browse files
cyanzheng2926cyanzheng2926
committed
Merge branch 'master' into HIVE-29627-isnull_selectivity
2 parents 56c6df6 + 46927a2 commit bc5ce85

155 files changed

Lines changed: 19041 additions & 2153 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎common/src/java/org/apache/hadoop/hive/conf/HiveConf.java‎

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5106,6 +5106,11 @@ public static enum ConfVars {
51065106
LLAP_ZK_REGISTRY_NAMESPACE("hive.llap.zk.registry.namespace", null,
51075107
"In the LLAP ZooKeeper-based registry, overrides the ZK path namespace. Note that\n" +
51085108
"using this makes the path management (e.g. setting correct ACLs) your responsibility."),
5109+
LLAP_CLUSTER_ROUTING_RULES("hive.llap.cluster.routing.rules", "",
5110+
"Comma-separated rules mapping users/groups to LLAP cluster names.\n" +
5111+
"Format: user:<name>=<cluster>,group:<name>=<cluster>,default=<cluster>.\n" +
5112+
"Per-cluster configs are read from hive.llap.cluster.<cluster>.sessions.namespace\n" +
5113+
"and hive.llap.cluster.<cluster>.registry.namespace."),
51095114
// Note: do not rename to ..service.acl; Hadoop generates .hosts setting name from this,
51105115
// resulting in a collision with existing hive.llap.daemon.service.hosts and bizarre errors.
51115116
// These are read by Hadoop IPC, so you should check the usage and naming conventions (e.g.
@@ -5560,7 +5565,8 @@ public static enum ConfVars {
55605565
"hive.iceberg.allow.datafiles.in.table.location.only," +
55615566
"hive.hook.proto.base-directory," +
55625567
"hive.rewrite.data.policy," +
5563-
"hive.query.history.enabled", // Query History service is initialized on HS2 startup (HIVE-29170)
5568+
"hive.query.history.enabled," + // Query History service is initialized on HS2 startup (HIVE-29170)
5569+
"hive.llap.cluster.routing.rules",
55645570
"Comma separated list of configuration options which are immutable at runtime"),
55655571
HIVE_CONF_HIDDEN_LIST("hive.conf.hidden.list",
55665572
METASTORE_PWD.varname + "," + HIVE_SERVER2_SSL_KEYSTORE_PASSWORD.varname

‎hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/DbNotificationListener.java‎

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1410,10 +1410,13 @@ private void addNotificationLogBatch(List<NotificationEvent> eventList, List<Lis
14101410

14111411
event.setEventId(nextEventId);
14121412
// Set the DB_NOTIFICATION_EVENT_ID for future reference by other listeners.
1413-
if (event.isSetEventId()) {
1413+
if (event.isSetEventId()
1414+
&& !listenerEvent
1415+
.getParameters()
1416+
.containsKey(MetaStoreEventListenerConstants.DB_NOTIFICATION_EVENT_ID_KEY_NAME)) {
14141417
listenerEvent.putParameter(
1415-
MetaStoreEventListenerConstants.DB_NOTIFICATION_EVENT_ID_KEY_NAME,
1416-
Long.toString(event.getEventId()));
1418+
MetaStoreEventListenerConstants.DB_NOTIFICATION_EVENT_ID_KEY_NAME,
1419+
Long.toString(event.getEventId()));
14171420
}
14181421
nextNLId++;
14191422
nextEventId++;
@@ -1431,17 +1434,19 @@ private void addNotificationLogBatch(List<NotificationEvent> eventList, List<Lis
14311434
* Process this notification by adding it to metastore DB.
14321435
*
14331436
* @param event NotificationEvent is the object written to the metastore DB.
1434-
* @param listenerEvent ListenerEvent (from which NotificationEvent was based) used only to set the
1435-
* DB_NOTIFICATION_EVENT_ID_KEY_NAME for future reference by other listeners.
1437+
* @param listenerEvent ListenerEvent (from which NotificationEvent was based) used only to set
1438+
* the DB_NOTIFICATION_EVENT_ID_KEY_NAME for future reference by other listeners.
14361439
*/
14371440
private void process(NotificationEvent event, ListenerEvent listenerEvent) throws MetaException {
14381441
event.setMessageFormat(msgEncoder.getMessageFormat());
1439-
LOG.debug("DbNotificationListener: Processing : {}:{}", event.getEventId(),
1440-
event.getMessage());
1442+
LOG.debug("DbNotificationListener: Processing : {}:{}", event.getEventId(), event.getMessage());
14411443
HMSHandler.getMSForConf(conf).addNotificationEvent(event);
14421444

14431445
// Set the DB_NOTIFICATION_EVENT_ID for future reference by other listeners.
1444-
if (event.isSetEventId()) {
1446+
if (event.isSetEventId()
1447+
&& !listenerEvent
1448+
.getParameters()
1449+
.containsKey(MetaStoreEventListenerConstants.DB_NOTIFICATION_EVENT_ID_KEY_NAME)) {
14451450
listenerEvent.putParameter(
14461451
MetaStoreEventListenerConstants.DB_NOTIFICATION_EVENT_ID_KEY_NAME,
14471452
Long.toString(event.getEventId()));

‎iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/BaseHiveIcebergMetaHook.java‎

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,6 @@ public class BaseHiveIcebergMetaHook implements HiveMetaHook {
9292
);
9393
private static final Set<String> PARAMETERS_TO_REMOVE = ImmutableSet
9494
.of(InputFormatConfig.TABLE_SCHEMA, Catalogs.LOCATION, Catalogs.NAME, InputFormatConfig.PARTITION_SPEC);
95-
static final String ORC_FILES_ONLY = "iceberg.orc.files.only";
9695
private static final String ZORDER_FIELDS_JSON_KEY = "zorderFields";
9796

9897
protected final Configuration conf;
@@ -214,8 +213,6 @@ public void preCreateTable(CreateTableRequest request) {
214213

215214
assertFileFormat(tableProperties.getProperty(TableProperties.DEFAULT_FILE_FORMAT));
216215

217-
// Set whether the format is ORC, to be used during vectorization.
218-
setOrcOnlyFilesParam(hmsTable);
219216
// Remove hive primary key columns from table request, as iceberg doesn't support hive primary key.
220217
request.setPrimaryKeys(null);
221218
setSortOrder(hmsTable, schema, tableProperties);
@@ -485,14 +482,6 @@ protected static PartitionSpec spec(Configuration configuration, Schema schema,
485482
return HMSTablePropertyHelper.getPartitionSpec(hmsTable.getParameters(), schema);
486483
}
487484

488-
protected void setOrcOnlyFilesParam(org.apache.hadoop.hive.metastore.api.Table hmsTable) {
489-
hmsTable.getParameters().put(ORC_FILES_ONLY, String.valueOf(isOrcOnlyFiles(hmsTable)));
490-
}
491-
492-
protected boolean isOrcOnlyFiles(org.apache.hadoop.hive.metastore.api.Table hmsTable) {
493-
return !"FALSE".equalsIgnoreCase(hmsTable.getParameters().get(ORC_FILES_ONLY)) && isOrcFileFormat(hmsTable);
494-
}
495-
496485
static boolean isOrcFileFormat(org.apache.hadoop.hive.metastore.api.Table hmsTable) {
497486
return hmsTable.getSd().getInputFormat() != null && hmsTable.getSd().getInputFormat().toUpperCase()
498487
.contains(org.apache.iceberg.FileFormat.ORC.name()) || org.apache.iceberg.FileFormat.ORC.name()

‎iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergInputFormat.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@
4646
import org.apache.hadoop.mapred.RecordReader;
4747
import org.apache.hadoop.mapred.Reporter;
4848
import org.apache.iceberg.FileScanTask;
49-
import org.apache.iceberg.TableProperties;
5049
import org.apache.iceberg.data.Record;
5150
import org.apache.iceberg.expressions.Expression;
5251
import org.apache.iceberg.expressions.Expressions;
@@ -69,7 +68,7 @@ public class HiveIcebergInputFormat extends MapredIcebergInputFormat<Record>
6968
LlapCacheOnlyInputFormatInterface.VectorizedOnly {
7069

7170
private static final Logger LOG = LoggerFactory.getLogger(HiveIcebergInputFormat.class);
72-
public static final String ICEBERG_DISABLE_VECTORIZATION_PREFIX = "iceberg.disable.vectorization.";
71+
public static final String ICEBERG_DISABLE_DECIMAL64_PREFIX = "iceberg.disable.decimal64.";
7372

7473
/**
7574
* Encapsulates planning-time and reader-time Iceberg filter expressions derived from Hive predicates.
@@ -249,16 +248,17 @@ public VectorizedSupport.Support[] getSupportedFeatures() {
249248

250249
@Override
251250
public VectorizedSupport.Support[] getSupportedFeatures(HiveConf hiveConf, TableDesc tableDesc) {
252-
// disabling VectorizedSupport.Support.DECIMAL_64 for Parquet as it doesn't support it
253-
boolean isORCOnly =
254-
Boolean.parseBoolean(tableDesc.getProperties().getProperty(HiveIcebergMetaHook.DECIMAL64_VECTORIZATION)) &&
255-
Boolean.parseBoolean(tableDesc.getProperties().getProperty(HiveIcebergMetaHook.ORC_FILES_ONLY)) &&
256-
org.apache.iceberg.FileFormat.ORC.name()
257-
.equalsIgnoreCase(tableDesc.getProperties().getProperty(TableProperties.DEFAULT_FILE_FORMAT));
258-
if (!isORCOnly) {
259-
final String vectorizationConfName = getVectorizationConfName(tableDesc.getTableName());
260-
LOG.debug("Setting {} for table: {} to true", vectorizationConfName, tableDesc.getTableName());
261-
hiveConf.set(vectorizationConfName, "true");
251+
// Both vectorizable file formats (ORC and Parquet) now support DECIMAL_64 reads, so advertise it
252+
// whenever decimal64 vectorization is enabled for the table, regardless of file format.
253+
boolean decimal64Enabled =
254+
Boolean.parseBoolean(tableDesc.getProperty(HiveIcebergMetaHook.DECIMAL64_VECTORIZATION));
255+
if (!decimal64Enabled) {
256+
// Keep the LLAP ORC reader from emitting decimal64 so it stays consistent with the full-decimal
257+
// operator pipeline; consumed in HiveVectorizedReader#orcRecordReader.
258+
final String decimal64DisableConfName = getDecimal64DisableConfName(tableDesc.getTableName());
259+
LOG.debug("Setting {} for table: {} to true", decimal64DisableConfName, tableDesc.getTableName());
260+
hiveConf.set(decimal64DisableConfName, "true");
261+
262262
return new VectorizedSupport.Support[] {};
263263
}
264264
return new VectorizedSupport.Support[] { VectorizedSupport.Support.DECIMAL_64 };
@@ -269,9 +269,9 @@ public void injectCaches(FileMetadataCache metadataCache, DataCache dataCache, C
269269
// no-op for Iceberg
270270
}
271271

272-
public static String getVectorizationConfName(String tableName) {
272+
public static String getDecimal64DisableConfName(String tableName) {
273273
String dbAndTableName = TableName.fromString(tableName, null, null).getNotEmptyDbTable();
274-
return ICEBERG_DISABLE_VECTORIZATION_PREFIX + dbAndTableName;
274+
return ICEBERG_DISABLE_DECIMAL64_PREFIX + dbAndTableName;
275275
}
276276

277277
@Override

‎iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergMetaHook.java‎

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -321,8 +321,6 @@ private void doPreAlterTable(org.apache.hadoop.hive.metastore.api.Table hmsTable
321321
// If so, we will create the iceberg table in commitAlterTable and go ahead with the migration
322322
assertTableCanBeMigrated(hmsTable);
323323
isTableMigration = true;
324-
// Set whether the format is ORC, to be used during vectorization.
325-
setOrcOnlyFilesParam(hmsTable);
326324

327325
StorageDescriptor sd = hmsTable.getSd();
328326
preAlterTableProperties = new PreAlterTableProperties();
@@ -385,13 +383,6 @@ private void doPreAlterTable(org.apache.hadoop.hive.metastore.api.Table hmsTable
385383
assertNotCrossTableMetadataLocationChange(hmsTable.getParameters(), context);
386384
}
387385

388-
// Migration case is already handled above, in case of migration we don't have all the properties set till this
389-
// point.
390-
if (!isTableMigration) {
391-
// Set whether the format is ORC, to be used during vectorization.
392-
setOrcOnlyFilesParam(hmsTable);
393-
}
394-
395386
}
396387

397388
/**

‎iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/vector/HiveVectorizedReader.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -213,10 +213,11 @@ private static RecordReader<NullWritable, VectorizedRowBatch> orcRecordReader(Jo
213213
// TODO: add support for reading files with positional deletes with LLAP (LLAP would need to provide file row num)
214214
if (HiveConf.getBoolVar(job, HiveConf.ConfVars.LLAP_IO_ENABLED, LlapProxy.isDaemon()) &&
215215
LlapProxy.getIo() != null && task.deletes().isEmpty() && !InputFormatConfig.fetchVirtualColumns(job)) {
216-
boolean isDisableVectorization =
217-
job.getBoolean(HiveIcebergInputFormat.getVectorizationConfName(tableName), false);
218-
if (isDisableVectorization) {
219-
// Required to prevent LLAP from dealing with decimal64, HiveIcebergInputFormat.getSupportedFeatures()
216+
boolean isDecimal64Disabled =
217+
job.getBoolean(HiveIcebergInputFormat.getDecimal64DisableConfName(tableName), false);
218+
if (isDecimal64Disabled) {
219+
// The LLAP ORC reader derives decimal64 support from this job var, not the plan; clear it so
220+
// it emits full decimal instead.
220221
HiveConf.setVar(job, HiveConf.ConfVars.HIVE_VECTORIZED_INPUT_FORMAT_SUPPORTS_ENABLED, "");
221222
}
222223
recordReader = LlapProxy.getIo().llapVectorizedOrcReaderForPath(fileId, path, null, readColumnIds,

‎iceberg/iceberg-handler/src/test/queries/positive/vectorized_iceberg_read_multitable.q‎

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,6 @@ insert into customer_ice values (10);
1111
create external table orders(o_orderkey int, o_custkey int) stored as orc;
1212
insert into orders values (10, 10);
1313

14-
alter table customer_ice set tblproperties ( 'iceberg.orc.files.only' = 'false');
15-
1614
select sum(1 - l_discount) as revenue
1715
FROM customer_ice, orders, lineitem
1816
WHERE c_custkey = o_custkey and l_orderkey = o_orderkey limit 20;
@@ -21,16 +19,6 @@ create external table lineitem_ice(l_discount decimal(15,2), l_orderkey int) STO
2119
TBLPROPERTIES ('iceberg.decimal64.vectorization'='true');
2220
insert into lineitem_ice values (100.2, 10);
2321

24-
select sum(1 - l_discount) as revenue
25-
FROM customer_ice, orders, lineitem_ice
26-
WHERE c_custkey = o_custkey and l_orderkey = o_orderkey limit 20;
27-
28-
alter table customer_ice set tblproperties ( 'iceberg.orc.files.only' = 'true');
29-
30-
select sum(1 - l_discount) as revenue
31-
FROM customer_ice, orders, lineitem
32-
WHERE c_custkey = o_custkey and l_orderkey = o_orderkey limit 20;
33-
3422
select sum(1 - l_discount) as revenue
3523
FROM customer_ice, orders, lineitem_ice
3624
WHERE c_custkey = o_custkey and l_orderkey = o_orderkey limit 20;

‎iceberg/iceberg-handler/src/test/results/positive/alter_multi_part_table_to_iceberg.q.out‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,6 @@ Table Parameters:
206206
current-snapshot-timestamp-ms #Masked#
207207
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001}]}
208208
format-version 2
209-
iceberg.orc.files.only true
210209
#### A masked pattern was here ####
211210
metadata_location hdfs://### HDFS PATH ###
212211
numFiles 7
@@ -482,7 +481,6 @@ Table Parameters:
482481
current-snapshot-timestamp-ms #Masked#
483482
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001}]}
484483
format-version 2
485-
iceberg.orc.files.only false
486484
#### A masked pattern was here ####
487485
metadata_location hdfs://### HDFS PATH ###
488486
numFiles 7
@@ -758,7 +756,6 @@ Table Parameters:
758756
current-snapshot-timestamp-ms #Masked#
759757
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001}]}
760758
format-version 2
761-
iceberg.orc.files.only false
762759
#### A masked pattern was here ####
763760
metadata_location hdfs://### HDFS PATH ###
764761
numFiles 7
@@ -1098,7 +1095,6 @@ Table Parameters:
10981095
current-snapshot-timestamp-ms #Masked#
10991096
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001},{\"name\":\"d\",\"transform\":\"identity\",\"source-id\":4,\"field-id\":1002}]}
11001097
format-version 2
1101-
iceberg.orc.files.only true
11021098
#### A masked pattern was here ####
11031099
metadata_location hdfs://### HDFS PATH ###
11041100
numFiles 10
@@ -1545,7 +1541,6 @@ Table Parameters:
15451541
current-snapshot-timestamp-ms #Masked#
15461542
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001},{\"name\":\"d\",\"transform\":\"identity\",\"source-id\":4,\"field-id\":1002}]}
15471543
format-version 2
1548-
iceberg.orc.files.only false
15491544
#### A masked pattern was here ####
15501545
metadata_location hdfs://### HDFS PATH ###
15511546
numFiles 10
@@ -1992,7 +1987,6 @@ Table Parameters:
19921987
current-snapshot-timestamp-ms #Masked#
19931988
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000},{\"name\":\"c\",\"transform\":\"identity\",\"source-id\":3,\"field-id\":1001},{\"name\":\"d\",\"transform\":\"identity\",\"source-id\":4,\"field-id\":1002}]}
19941989
format-version 2
1995-
iceberg.orc.files.only false
19961990
#### A masked pattern was here ####
19971991
metadata_location hdfs://### HDFS PATH ###
19981992
numFiles 10

‎iceberg/iceberg-handler/src/test/results/positive/alter_part_table_to_iceberg.q.out‎

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,6 @@ Table Parameters:
163163
current-snapshot-timestamp-ms #Masked#
164164
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000}]}
165165
format-version 2
166-
iceberg.orc.files.only true
167166
#### A masked pattern was here ####
168167
metadata_location hdfs://### HDFS PATH ###
169168
numFiles 4
@@ -441,7 +440,6 @@ Table Parameters:
441440
current-snapshot-timestamp-ms #Masked#
442441
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000}]}
443442
format-version 2
444-
iceberg.orc.files.only false
445443
#### A masked pattern was here ####
446444
metadata_location hdfs://### HDFS PATH ###
447445
numFiles 7
@@ -796,7 +794,6 @@ Table Parameters:
796794
current-snapshot-timestamp-ms #Masked#
797795
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000}]}
798796
format-version 2
799-
iceberg.orc.files.only false
800797
#### A masked pattern was here ####
801798
metadata_location hdfs://### HDFS PATH ###
802799
numFiles 7
@@ -1151,7 +1148,6 @@ Table Parameters:
11511148
current-snapshot-timestamp-ms #Masked#
11521149
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000}]}
11531150
format-version 2
1154-
iceberg.orc.files.only false
11551151
#### A masked pattern was here ####
11561152
metadata_location hdfs://### HDFS PATH ###
11571153
numFiles 7
@@ -1452,7 +1448,6 @@ Table Parameters:
14521448
current-snapshot-timestamp-ms #Masked#
14531449
default-partition-spec {\"spec-id\":0,\"fields\":[{\"name\":\"b\",\"transform\":\"identity\",\"source-id\":2,\"field-id\":1000}]}
14541450
format-version 2
1455-
iceberg.orc.files.only false
14561451
#### A masked pattern was here ####
14571452
metadata_location hdfs://### HDFS PATH ###
14581453
numFiles 4

‎iceberg/iceberg-handler/src/test/results/positive/alter_table_to_iceberg.q.out‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,6 @@ Table Parameters:
113113
current-snapshot-summary {\"added-data-files\":\"1\",\"added-records\":\"5\",\"added-files-size\":\"#Masked#\",\"changed-partition-count\":\"1\",\"total-records\":\"5\",\"total-files-size\":\"#Masked#\",\"total-data-files\":\"1\",\"total-delete-files\":\"0\",\"total-position-deletes\":\"0\",\"total-equality-deletes\":\"0\",\"iceberg-version\":\"#Masked#\"}
114114
current-snapshot-timestamp-ms #Masked#
115115
format-version 2
116-
iceberg.orc.files.only true
117116
#### A masked pattern was here ####
118117
metadata_location hdfs://### HDFS PATH ###
119118
numFiles 1
@@ -284,7 +283,6 @@ Table Parameters:
284283
current-snapshot-summary {\"added-data-files\":\"1\",\"added-records\":\"5\",\"added-files-size\":\"#Masked#\",\"changed-partition-count\":\"1\",\"total-records\":\"5\",\"total-files-size\":\"#Masked#\",\"total-data-files\":\"1\",\"total-delete-files\":\"0\",\"total-position-deletes\":\"0\",\"total-equality-deletes\":\"0\",\"iceberg-version\":\"#Masked#\"}
285284
current-snapshot-timestamp-ms #Masked#
286285
format-version 2
287-
iceberg.orc.files.only false
288286
#### A masked pattern was here ####
289287
metadata_location hdfs://### HDFS PATH ###
290288
numFiles 1
@@ -455,7 +453,6 @@ Table Parameters:
455453
current-snapshot-summary {\"added-data-files\":\"1\",\"added-records\":\"5\",\"added-files-size\":\"#Masked#\",\"changed-partition-count\":\"1\",\"total-records\":\"5\",\"total-files-size\":\"#Masked#\",\"total-data-files\":\"1\",\"total-delete-files\":\"0\",\"total-position-deletes\":\"0\",\"total-equality-deletes\":\"0\",\"iceberg-version\":\"#Masked#\"}
456454
current-snapshot-timestamp-ms #Masked#
457455
format-version 2
458-
iceberg.orc.files.only false
459456
#### A masked pattern was here ####
460457
metadata_location hdfs://### HDFS PATH ###
461458
numFiles 1

0 commit comments

Comments
 (0)