use metrics config in appender factory

apache · Dec 18, 2020 · 03a1b42 · 03a1b42
1 parent 8498aff
commit 03a1b42
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/data/src/main/java/org/apache/iceberg/data/GenericAppenderFactory.java b/data/src/main/java/org/apache/iceberg/data/GenericAppenderFactory.java
@@ -92,6 +92,7 @@ public FileAppender<Record> newAppender(OutputFile outputFile, FileFormat fileFo
           return Avro.write(outputFile)
               .schema(schema)
               .createWriterFunc(DataWriter::create)
+              .metricsConfig(metricsConfig)
               .setAll(config)
               .overwrite()
               .build();

diff --git a/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java b/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
@@ -102,6 +102,7 @@ public FileAppender<RowData> newAppender(OutputFile outputFile, FileFormat forma
               .createWriterFunc(ignore -> new FlinkAvroWriter(flinkSchema))
               .setAll(props)
               .schema(schema)
+              .metricsConfig(metricsConfig)
               .overwrite()
               .build();