From e6a4e0d709917fab823b06d45a4dbe2e8d7368f5 Mon Sep 17 00:00:00 2001
From: Nga Tran <ntran@influxdata.com>
Date: Tue, 29 Jun 2021 17:46:30 -0400
Subject: [PATCH] refactor: make the code clearer for schema even though they
 are the same

---
 query/src/provider/deduplicate/algo.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/query/src/provider/deduplicate/algo.rs b/query/src/provider/deduplicate/algo.rs
index 3633d11c48..21e88635bd 100644
--- a/query/src/provider/deduplicate/algo.rs
+++ b/query/src/provider/deduplicate/algo.rs
@@ -97,8 +97,8 @@ impl RecordBatchDeduplicator {
             let lines = formatted.trim().split('\n').collect::<Vec<_>>();
             println!("\nBatch::\n\n{:#?}\n\n", lines);
 
-            let schema = last_batch.schema();
             // Build sorted columns for last_batch and current one
+            let schema = last_batch.schema();
             let last_batch_key_columns = self
                 .sort_keys
                 .iter()
@@ -120,6 +120,7 @@ impl RecordBatchDeduplicator {
                 .collect::<Vec<arrow::compute::SortColumn>>();
 
             // Build sorted columns for current batch
+            let schema = batch.schema();
             let batch_key_columns = self
                 .sort_keys
                 .iter()