From 265d9cfa599bc5969efd33f9f4c400f63a9aae18 Mon Sep 17 00:00:00 2001 From: Nathan Fox Date: Tue, 1 Nov 2022 10:25:50 -0400 Subject: [PATCH] chore(filter transform): add log namespace support to filter transform (#15036) add log namespace support --- src/transforms/filter.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/transforms/filter.rs b/src/transforms/filter.rs index be05dca2d01d1..e0bb659655961 100644 --- a/src/transforms/filter.rs +++ b/src/transforms/filter.rs @@ -46,8 +46,8 @@ impl TransformConfig for FilterConfig { Input::all() } - fn outputs(&self, _: &schema::Definition) -> Vec { - vec![Output::default(DataType::all())] + fn outputs(&self, merged_definition: &schema::Definition) -> Vec { + vec![Output::default(DataType::all()).with_schema_definition(merged_definition.clone())] } fn enable_concurrency(&self) -> bool {