Iceberg writer stage should include WRITER_MAXIMUM_POOL_SIZE in its p…

…arameters (#170)
Netflix · Apr 13, 2022 · 6f42639 · 6f42639
1 parent d8c82e1
commit 6f42639
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...r-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java b/...r-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java
@@ -102,7 +102,12 @@ public static List<ParameterDefinition<?>> parameters() {
                         .description(WriterProperties.WRITER_FILE_FORMAT_DESCRIPTION)
                         .validator(Validators.alwaysPass())
                         .defaultValue(WriterProperties.WRITER_FILE_FORMAT_DEFAULT)
-                        .build()
+                        .build(),
+                new IntParameter().name(WriterProperties.WRITER_MAXIMUM_POOL_SIZE)
+                    .description(WriterProperties.WRITER_MAXIMUM_POOL_SIZE_DESCRIPTION)
+                    .validator(Validators.alwaysPass())
+                    .defaultValue(WriterProperties.WRITER_MAXIMUM_POOL_SIZE_DEFAULT)
+                    .build()
         );
     }