From 79bdbdfd2fc1a73ccc44e29bae803db2607923d9 Mon Sep 17 00:00:00 2001
From: Noel Kwan <noelkwan1998@gmail.com>
Date: Wed, 6 Nov 2024 15:31:14 +0800
Subject: [PATCH] clean

---
 src/connector/src/source/iceberg/mod.rs       | 1 -
 src/frontend/src/scheduler/plan_fragmenter.rs | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/connector/src/source/iceberg/mod.rs b/src/connector/src/source/iceberg/mod.rs
index e717d604a31a..58faf022322a 100644
--- a/src/connector/src/source/iceberg/mod.rs
+++ b/src/connector/src/source/iceberg/mod.rs
@@ -251,7 +251,6 @@ impl IcebergSplitEnumerator {
         let mut position_delete_files = vec![];
         let mut data_files = vec![];
         let mut equality_delete_files = vec![];
-        // TODO(kwannoel): add filter here.
         let scan = table
             .scan()
             .with_filter(predicate)
diff --git a/src/frontend/src/scheduler/plan_fragmenter.rs b/src/frontend/src/scheduler/plan_fragmenter.rs
index 35eafa8a8be8..9cec27601a24 100644
--- a/src/frontend/src/scheduler/plan_fragmenter.rs
+++ b/src/frontend/src/scheduler/plan_fragmenter.rs
@@ -270,7 +270,7 @@ impl Query {
 }
 
 #[derive(Debug, Clone)]
-enum SourceFetchParameters {
+pub enum SourceFetchParameters {
     IcebergPredicate(IcebergPredicate),
     KafkaTimebound {
         lower: Option<i64>,