From ca98744e28747b362658116214cd57472ec2dd07 Mon Sep 17 00:00:00 2001 From: Dylan Chen Date: Tue, 6 Aug 2024 16:55:24 +0800 Subject: [PATCH] fmt --- src/batch/src/executor/iceberg_scan.rs | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/batch/src/executor/iceberg_scan.rs b/src/batch/src/executor/iceberg_scan.rs index 58878901f60fa..ee4e463422c14 100644 --- a/src/batch/src/executor/iceberg_scan.rs +++ b/src/batch/src/executor/iceberg_scan.rs @@ -16,7 +16,6 @@ use std::mem; use futures_async_stream::try_stream; use futures_util::stream::StreamExt; -use iceberg::arrow::ArrowReader; use iceberg::scan::FileScanTask; use iceberg::spec::TableMetadata; use risingwave_common::array::arrow::IcebergArrowConvert; @@ -80,7 +79,6 @@ impl IcebergScanExecutor { .await?; let data_types = self.schema.data_types(); - let tasks_len = self.file_scan_tasks.len(); let file_scan_tasks = mem::take(&mut self.file_scan_tasks); let file_scan_stream = {