diff --git a/amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/GenericTaskWriters.java b/amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/GenericTaskWriters.java index 7a655092a8..5857402f5c 100644 --- a/amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/GenericTaskWriters.java +++ b/amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/GenericTaskWriters.java @@ -131,7 +131,7 @@ public GenericBaseTaskWriter buildBaseWriter() { - 1; return new GenericBaseTaskWriter( fileFormat, - new GenericAppenderFactory(base.schema(), table.spec()), + new GenericAppenderFactory(base.schema(), table.spec()).setAll(table.properties()), new CommonOutputFileFactory( base.location(), table.spec(), @@ -161,7 +161,7 @@ public SortedPosDeleteWriter buildBasePosDeleteWriter( TableProperties.BASE_FILE_FORMAT, TableProperties.BASE_FILE_FORMAT_DEFAULT) .toUpperCase(Locale.ENGLISH))); GenericAppenderFactory appenderFactory = - new GenericAppenderFactory(base.schema(), table.spec()); + new GenericAppenderFactory(base.schema(), table.spec()).setAll(table.properties()); appenderFactory.set( org.apache.iceberg.TableProperties.METRICS_MODE_COLUMN_CONF_PREFIX + MetadataColumns.DELETE_FILE_PATH.name(), @@ -219,7 +219,7 @@ public GenericChangeTaskWriter buildChangeWriter() { Schema changeWriteSchema = SchemaUtil.changeWriteSchema(change.schema()); return new GenericChangeTaskWriter( fileFormat, - new GenericAppenderFactory(changeWriteSchema, table.spec()), + new GenericAppenderFactory(changeWriteSchema, table.spec()).setAll(table.properties()), new CommonOutputFileFactory( change.location(), table.spec(), diff --git a/amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestKeyedTable.java b/amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestKeyedTable.java index a6e474f3c4..a33f05ab23 100644 --- a/amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestKeyedTable.java +++ b/amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestKeyedTable.java @@ -62,7 +62,7 @@ public void testStats() { .matches( "VALUES " + "('id', NULL, NULL, 0e0, NULL, '1', '4'), " - + "('name$name', 548e0, NULL, 0e0, NULL, NULL, NULL), " + + "('name$name', 429e0, NULL, 0e0, NULL, NULL, NULL), " + "('op_time', NULL, NULL, 0e0, NULL, '2022-01-01 12:00:00.000000', '2022-01-04 12:00:00.000000'), " + "(NULL, NULL, NULL, NULL, 4e0, NULL, NULL)"); }