This is an automated email from the ASF dual-hosted git repository.
zhangstar333 pushed a commit to branch iceberg-v3-test-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/iceberg-v3-test-branch-4.1 by
this push:
new be0265e2cc5 add iceberg logs
be0265e2cc5 is described below
commit be0265e2cc5b720c7c626c7447b2f24bcffa6993
Author: zhangstar333 <[email protected]>
AuthorDate: Thu Jun 4 11:27:03 2026 +0800
add iceberg logs
---
.../main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java
index bd8680d1321..e162370e732 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java
@@ -1089,12 +1089,16 @@ public class IcebergUtils {
public static FileFormat getFileFormat(Table icebergTable) {
Map<String, String> properties = icebergTable.properties();
+ for (Map.Entry<String, String> entry : properties.entrySet()) {
+ LOG.info("asd Iceberg table property: {}={}", entry.getKey(),
entry.getValue());
+ }
String fileFormatName;
if (properties.containsKey(WRITE_FORMAT)) {
fileFormatName = properties.get(WRITE_FORMAT);
} else {
fileFormatName =
properties.getOrDefault(TableProperties.DEFAULT_FILE_FORMAT, PARQUET_NAME);
}
+ LOG.info("asd Iceberg table {}.{} file format is {}",
icebergTable.name(), fileFormatName);
FileFormat fileFormat;
if (fileFormatName.toLowerCase().contains(ORC_NAME)) {
fileFormat = FileFormat.ORC;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
