diff --git a/src/executor/operator/physical_aggregate.cppm b/src/executor/operator/physical_aggregate.cppm
index d3c2e7532f..e40396b43e 100644
--- a/src/executor/operator/physical_aggregate.cppm
+++ b/src/executor/operator/physical_aggregate.cppm
@@ -57,12 +57,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     void GroupByInputTable(const Vector<UniquePtr<DataBlock>> &input_blocks, Vector<UniquePtr<DataBlock>> &output_blocks, HashTable &hash_table);
 
     void GenerateGroupByResult(const SharedPtr<DataTable> &input_table, SharedPtr<DataTable> &output_table, HashTable &hash_table);
diff --git a/src/executor/operator/physical_alter.cppm b/src/executor/operator/physical_alter.cppm
index efbb714d97..4cc93a8199 100644
--- a/src/executor/operator/physical_alter.cppm
+++ b/src/executor/operator/physical_alter.cppm
@@ -47,12 +47,6 @@ public:
 
     ~PhysicalAlter() override = default;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_command.cpp b/src/executor/operator/physical_command.cpp
index 0f9e2bc754..0fa60c71a8 100644
--- a/src/executor/operator/physical_command.cpp
+++ b/src/executor/operator/physical_command.cpp
@@ -558,10 +558,4 @@ bool PhysicalCommand::Execute(QueryContext *query_context, OperatorState *operat
     return true;
 }
 
-SizeT PhysicalCommand::TaskletCount() {
-    String error_message = "Not implement: TaskletCount not Implement";
-    UnrecoverableError(error_message);
-    return 0;
-}
-
 } // namespace infinity
\ No newline at end of file
diff --git a/src/executor/operator/physical_command.cppm b/src/executor/operator/physical_command.cppm
index c4077d1e1a..230844ce9a 100644
--- a/src/executor/operator/physical_command.cppm
+++ b/src/executor/operator/physical_command.cppm
@@ -48,8 +48,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) override;
 
-    SizeT TaskletCount() override;
-
     inline SharedPtr<Vector<String>> GetOutputNames() const override { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
diff --git a/src/executor/operator/physical_compact_finish.cppm b/src/executor/operator/physical_compact_finish.cppm
index 9f52e30f05..e2f712d106 100644
--- a/src/executor/operator/physical_compact_finish.cppm
+++ b/src/executor/operator/physical_compact_finish.cppm
@@ -54,12 +54,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     void SaveSegmentData(QueryContext *query_context, const CompactStateData *compact_state_data);
 
diff --git a/src/executor/operator/physical_compact_index_prepare.cpp b/src/executor/operator/physical_compact_index_prepare.cpp
index 446b564f9d..1f194122eb 100644
--- a/src/executor/operator/physical_compact_index_prepare.cpp
+++ b/src/executor/operator/physical_compact_index_prepare.cpp
@@ -83,10 +83,4 @@ bool PhysicalCompactIndexPrepare::Execute(QueryContext *query_context, OperatorS
     return true;
 }
 
-SizeT PhysicalCompactIndexPrepare::TaskletCount() {
-    // auto *index_index = base_table_ref_->index_index_.get();
-    // return index_index->index_snapshots_vec_.size();
-    return 1;
-}
-
 } // namespace infinity
\ No newline at end of file
diff --git a/src/executor/operator/physical_compact_index_prepare.cppm b/src/executor/operator/physical_compact_index_prepare.cppm
index c21471dc29..f10ba46413 100644
--- a/src/executor/operator/physical_compact_index_prepare.cppm
+++ b/src/executor/operator/physical_compact_index_prepare.cppm
@@ -45,8 +45,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) override;
 
-    SizeT TaskletCount() override;
-
     inline SharedPtr<Vector<String>> GetOutputNames() const override { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
diff --git a/src/executor/operator/physical_create_collection.cppm b/src/executor/operator/physical_create_collection.cppm
index 0df37bf05a..0a6f0b59f1 100644
--- a/src/executor/operator/physical_create_collection.cppm
+++ b/src/executor/operator/physical_create_collection.cppm
@@ -48,12 +48,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_create_index_finish.cppm b/src/executor/operator/physical_create_index_finish.cppm
index 854ccc6f11..637d363841 100644
--- a/src/executor/operator/physical_create_index_finish.cppm
+++ b/src/executor/operator/physical_create_index_finish.cppm
@@ -44,8 +44,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) override;
 
-    SizeT TaskletCount() override { return 1; }
-
     SharedPtr<Vector<String>> GetOutputNames() const override { return output_names_; }
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
diff --git a/src/executor/operator/physical_create_index_prepare.cppm b/src/executor/operator/physical_create_index_prepare.cppm
index d4338bea0d..636c78eb88 100644
--- a/src/executor/operator/physical_create_index_prepare.cppm
+++ b/src/executor/operator/physical_create_index_prepare.cppm
@@ -46,8 +46,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) override;
 
-    SizeT TaskletCount() override { return 1; }
-
     SharedPtr<Vector<String>> GetOutputNames() const override { return output_names_; }
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
diff --git a/src/executor/operator/physical_create_schema.cppm b/src/executor/operator/physical_create_schema.cppm
index 604b333f2f..63ada4c3a8 100644
--- a/src/executor/operator/physical_create_schema.cppm
+++ b/src/executor/operator/physical_create_schema.cppm
@@ -51,12 +51,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_create_table.cppm b/src/executor/operator/physical_create_table.cppm
index 17041be9c8..ff75af6532 100644
--- a/src/executor/operator/physical_create_table.cppm
+++ b/src/executor/operator/physical_create_table.cppm
@@ -59,11 +59,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_create_view.cppm b/src/executor/operator/physical_create_view.cppm
index e6eb3d08ac..05738fbdd9 100644
--- a/src/executor/operator/physical_create_view.cppm
+++ b/src/executor/operator/physical_create_view.cppm
@@ -48,12 +48,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline const SharedPtr<CreateViewInfo> &bound_select_statement() const { return create_view_info_; };
 
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
diff --git a/src/executor/operator/physical_cross_product.cppm b/src/executor/operator/physical_cross_product.cppm
index 8d35bcf7b0..1efbc06f40 100644
--- a/src/executor/operator/physical_cross_product.cppm
+++ b/src/executor/operator/physical_cross_product.cppm
@@ -42,12 +42,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     SharedPtr<Vector<String>> GetOutputNames() const final;
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final;
diff --git a/src/executor/operator/physical_delete.cppm b/src/executor/operator/physical_delete.cppm
index 20b5042360..4465f64293 100644
--- a/src/executor/operator/physical_delete.cppm
+++ b/src/executor/operator/physical_delete.cppm
@@ -42,12 +42,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_drop_collection.cppm b/src/executor/operator/physical_drop_collection.cppm
index ebf65034ef..9cd0a3e5f6 100644
--- a/src/executor/operator/physical_drop_collection.cppm
+++ b/src/executor/operator/physical_drop_collection.cppm
@@ -47,12 +47,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_drop_index.cppm b/src/executor/operator/physical_drop_index.cppm
index 21881c8c45..69c3824ad0 100644
--- a/src/executor/operator/physical_drop_index.cppm
+++ b/src/executor/operator/physical_drop_index.cppm
@@ -52,12 +52,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) override;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const override { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const override { return output_types_; }
diff --git a/src/executor/operator/physical_drop_schema.cppm b/src/executor/operator/physical_drop_schema.cppm
index c881d43de6..bf1ad496a4 100644
--- a/src/executor/operator/physical_drop_schema.cppm
+++ b/src/executor/operator/physical_drop_schema.cppm
@@ -48,12 +48,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_drop_table.cppm b/src/executor/operator/physical_drop_table.cppm
index 35e7d21304..19893ab732 100644
--- a/src/executor/operator/physical_drop_table.cppm
+++ b/src/executor/operator/physical_drop_table.cppm
@@ -50,12 +50,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_drop_view.cppm b/src/executor/operator/physical_drop_view.cppm
index 2ebfd23964..efa865c0ae 100644
--- a/src/executor/operator/physical_drop_view.cppm
+++ b/src/executor/operator/physical_drop_view.cppm
@@ -49,12 +49,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_dummy_operator.cppm b/src/executor/operator/physical_dummy_operator.cppm
index aecc04cc12..636d721dfc 100644
--- a/src/executor/operator/physical_dummy_operator.cppm
+++ b/src/executor/operator/physical_dummy_operator.cppm
@@ -41,12 +41,6 @@ public:
 
     bool Execute(QueryContext *query_context, OperatorState *operator_state) final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SharedPtr<Vector<String>> GetOutputNames() const final { return output_names_; }
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
diff --git a/src/executor/operator/physical_dummy_scan.cppm b/src/executor/operator/physical_dummy_scan.cppm
index 9fc800fcf7..20a86c59c2 100644
--- a/src/executor/operator/physical_dummy_scan.cppm
+++ b/src/executor/operator/physical_dummy_scan.cppm
@@ -45,12 +45,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_except.cppm b/src/executor/operator/physical_except.cppm
index 7f44c01f7e..31e1a7d3f5 100644
--- a/src/executor/operator/physical_except.cppm
+++ b/src/executor/operator/physical_except.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_explain.cppm b/src/executor/operator/physical_explain.cppm
index 63616bd422..9b618ece04 100644
--- a/src/executor/operator/physical_explain.cppm
+++ b/src/executor/operator/physical_explain.cppm
@@ -55,12 +55,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline ExplainType explain_type() const { return explain_type_; }
 
     static void AlignParagraphs(Vector<SharedPtr<String>> &array1, Vector<SharedPtr<String>> &array2);
diff --git a/src/executor/operator/physical_export.cppm b/src/executor/operator/physical_export.cppm
index 11612a60e4..369c9fe686 100644
--- a/src/executor/operator/physical_export.cppm
+++ b/src/executor/operator/physical_export.cppm
@@ -68,12 +68,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     SizeT ExportToCSV(QueryContext *query_context, ExportOperatorState *export_op_state);
 
     SizeT ExportToJSONL(QueryContext *query_context, ExportOperatorState *export_op_state);
diff --git a/src/executor/operator/physical_flush.cppm b/src/executor/operator/physical_flush.cppm
index 0c66a716ef..fb862e408c 100644
--- a/src/executor/operator/physical_flush.cppm
+++ b/src/executor/operator/physical_flush.cppm
@@ -47,12 +47,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline FlushType flush_type() const { return flush_type_; }
 
 private:
diff --git a/src/executor/operator/physical_hash.cppm b/src/executor/operator/physical_hash.cppm
index acb0ddff1d..c5f5f958a8 100644
--- a/src/executor/operator/physical_hash.cppm
+++ b/src/executor/operator/physical_hash.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_hash_join.cppm b/src/executor/operator/physical_hash_join.cppm
index b980f52e16..73c1e2f795 100644
--- a/src/executor/operator/physical_hash_join.cppm
+++ b/src/executor/operator/physical_hash_join.cppm
@@ -44,12 +44,6 @@ public:
     SharedPtr<Vector<String>> GetOutputNames() const final;
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final;
-
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
 };
 
 } // namespace infinity
diff --git a/src/executor/operator/physical_import.cppm b/src/executor/operator/physical_import.cppm
index 1b5b1ad22f..7dc54a1e54 100644
--- a/src/executor/operator/physical_import.cppm
+++ b/src/executor/operator/physical_import.cppm
@@ -86,12 +86,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     void ImportFVECS(QueryContext *query_context, ImportOperatorState *import_op_state);
 
     void ImportCSR(QueryContext *query_context, ImportOperatorState *import_op_state);
diff --git a/src/executor/operator/physical_index_join.cppm b/src/executor/operator/physical_index_join.cppm
index 137336ac88..42d7eb8947 100644
--- a/src/executor/operator/physical_index_join.cppm
+++ b/src/executor/operator/physical_index_join.cppm
@@ -44,12 +44,6 @@ public:
     SharedPtr<Vector<String>> GetOutputNames() const final;
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final;
-
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
 };
 
 } // namespace infinity
diff --git a/src/executor/operator/physical_insert.cppm b/src/executor/operator/physical_insert.cppm
index 3386f66c45..d700523da7 100644
--- a/src/executor/operator/physical_insert.cppm
+++ b/src/executor/operator/physical_insert.cppm
@@ -56,12 +56,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     TableEntry *table_entry_{};
     u64 table_index_{};
diff --git a/src/executor/operator/physical_intersect.cppm b/src/executor/operator/physical_intersect.cppm
index 84dd92f0aa..e419b7bc50 100644
--- a/src/executor/operator/physical_intersect.cppm
+++ b/src/executor/operator/physical_intersect.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_merge_aggregate.cppm b/src/executor/operator/physical_merge_aggregate.cppm
index 2821764108..d1c40897cd 100644
--- a/src/executor/operator/physical_merge_aggregate.cppm
+++ b/src/executor/operator/physical_merge_aggregate.cppm
@@ -55,12 +55,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     template <typename T>
     T GetInputData(MergeAggregateOperatorState *op_state, SizeT block_index, SizeT col_idx, SizeT row_idx);
 
diff --git a/src/executor/operator/physical_merge_hash.cppm b/src/executor/operator/physical_merge_hash.cppm
index 7e0db739c4..4041e9f53b 100644
--- a/src/executor/operator/physical_merge_hash.cppm
+++ b/src/executor/operator/physical_merge_hash.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_merge_limit.cppm b/src/executor/operator/physical_merge_limit.cppm
index c61a88f318..7647e54285 100644
--- a/src/executor/operator/physical_merge_limit.cppm
+++ b/src/executor/operator/physical_merge_limit.cppm
@@ -52,12 +52,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return left_->GetOutputTypes(); }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     [[nodiscard]] inline const SharedPtr<BaseExpression> &limit_expr() const { return limit_expr_; }
 
     [[nodiscard]] inline const SharedPtr<BaseExpression> &offset_expr() const { return offset_expr_; }
diff --git a/src/executor/operator/physical_merge_parallel_aggregate.cppm b/src/executor/operator/physical_merge_parallel_aggregate.cppm
index eb9d943842..4a252e9e75 100644
--- a/src/executor/operator/physical_merge_parallel_aggregate.cppm
+++ b/src/executor/operator/physical_merge_parallel_aggregate.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_merge_sort.cppm b/src/executor/operator/physical_merge_sort.cppm
index 78ee8d91c0..f77d9cf818 100644
--- a/src/executor/operator/physical_merge_sort.cppm
+++ b/src/executor/operator/physical_merge_sort.cppm
@@ -49,12 +49,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_nested_loop_join.cppm b/src/executor/operator/physical_nested_loop_join.cppm
index 9b6d5f42cc..6151f73191 100644
--- a/src/executor/operator/physical_nested_loop_join.cppm
+++ b/src/executor/operator/physical_nested_loop_join.cppm
@@ -54,12 +54,6 @@ public:
 
     SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final;
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline const Vector<SharedPtr<BaseExpression>> &conditions() const { return conditions_; }
 
 private:
diff --git a/src/executor/operator/physical_optimize.cppm b/src/executor/operator/physical_optimize.cppm
index 3ac7acb801..179962fdc4 100644
--- a/src/executor/operator/physical_optimize.cppm
+++ b/src/executor/operator/physical_optimize.cppm
@@ -54,12 +54,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     void OptimizeIndex(QueryContext *query_context, OperatorState *operator_state);
 
diff --git a/src/executor/operator/physical_parallel_aggregate.cppm b/src/executor/operator/physical_parallel_aggregate.cppm
index f7827063fe..3ab9634ebe 100644
--- a/src/executor/operator/physical_parallel_aggregate.cppm
+++ b/src/executor/operator/physical_parallel_aggregate.cppm
@@ -50,12 +50,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_prepared_plan.cppm b/src/executor/operator/physical_prepared_plan.cppm
index 325bac71a2..a72dd6d359 100644
--- a/src/executor/operator/physical_prepared_plan.cppm
+++ b/src/executor/operator/physical_prepared_plan.cppm
@@ -46,12 +46,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_scan/physical_merge_knn.cppm b/src/executor/operator/physical_scan/physical_merge_knn.cppm
index de95b0600c..275624ca43 100644
--- a/src/executor/operator/physical_scan/physical_merge_knn.cppm
+++ b/src/executor/operator/physical_scan/physical_merge_knn.cppm
@@ -61,12 +61,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline bool IsKnnMinHeap() const { return knn_expression_->IsKnnMinHeap(); }
 
 private:
diff --git a/src/executor/operator/physical_show.cppm b/src/executor/operator/physical_show.cppm
index 1ff4c763f8..408ddba3b5 100644
--- a/src/executor/operator/physical_show.cppm
+++ b/src/executor/operator/physical_show.cppm
@@ -66,12 +66,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline ShowStmtType show_type() const { return show_type_; }
 
     inline const String &db_name() const { return db_name_; };
diff --git a/src/executor/operator/physical_sink.cppm b/src/executor/operator/physical_sink.cppm
index f8513879e1..ad0d42c818 100644
--- a/src/executor/operator/physical_sink.cppm
+++ b/src/executor/operator/physical_sink.cppm
@@ -63,12 +63,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SinkType sink_type() const { return type_; }
 
 private:
diff --git a/src/executor/operator/physical_sort_merge_join.cppm b/src/executor/operator/physical_sort_merge_join.cppm
index f0146bb250..0e6b0a211e 100644
--- a/src/executor/operator/physical_sort_merge_join.cppm
+++ b/src/executor/operator/physical_sort_merge_join.cppm
@@ -45,12 +45,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_source.cppm b/src/executor/operator/physical_source.cppm
index cc52f13b7a..278f495643 100644
--- a/src/executor/operator/physical_source.cppm
+++ b/src/executor/operator/physical_source.cppm
@@ -62,12 +62,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     inline SourceType source_type() const { return type_; }
 
 private:
diff --git a/src/executor/operator/physical_union_all.cppm b/src/executor/operator/physical_union_all.cppm
index e727365dbb..d53a9a0f5e 100644
--- a/src/executor/operator/physical_union_all.cppm
+++ b/src/executor/operator/physical_union_all.cppm
@@ -47,12 +47,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
 private:
     SharedPtr<Vector<String>> output_names_{};
     SharedPtr<Vector<SharedPtr<DataType>>> output_types_{};
diff --git a/src/executor/operator/physical_update.cppm b/src/executor/operator/physical_update.cppm
index ff3c4967af..2cdd205d98 100644
--- a/src/executor/operator/physical_update.cppm
+++ b/src/executor/operator/physical_update.cppm
@@ -54,12 +54,6 @@ public:
 
     inline SharedPtr<Vector<SharedPtr<DataType>>> GetOutputTypes() const final { return output_types_; }
 
-    SizeT TaskletCount() override {
-        String error_message = "Not implement: TaskletCount not Implement";
-        UnrecoverableError(error_message);
-        return 0;
-    }
-
     TableEntry *table_entry_ptr_;
     const Vector<Pair<SizeT, SharedPtr<BaseExpression>>> &update_columns_;
     const Vector<SharedPtr<BaseExpression>> &all_columns_in_table_;
diff --git a/src/executor/physical_operator.cpp b/src/executor/physical_operator.cpp
index 37f01f3d98..6a658213a8 100644
--- a/src/executor/physical_operator.cpp
+++ b/src/executor/physical_operator.cpp
@@ -42,6 +42,8 @@ import block_index;
 
 namespace infinity {
 
+SizeT PhysicalOperator::TaskletCount() { return 1; }
+
 String PhysicalOperator::GetName() const { return PhysicalOperatorToString(operator_type_); }
 
 void PhysicalOperator::InputLoad(QueryContext *query_context, OperatorState *operator_state, HashMap<SizeT, SharedPtr<BaseTableRef>> &table_refs) {
diff --git a/src/executor/physical_operator.cppm b/src/executor/physical_operator.cppm
index 54bbec0c4f..68bd8f95f6 100644
--- a/src/executor/physical_operator.cppm
+++ b/src/executor/physical_operator.cppm
@@ -55,7 +55,7 @@ public:
 
     virtual void Init() = 0;
 
-    virtual SizeT TaskletCount() = 0;
+    virtual SizeT TaskletCount();
 
     inline PhysicalOperator *left() const { return left_.get(); }
 
diff --git a/src/scheduler/fragment_context.cpp b/src/scheduler/fragment_context.cpp
index b7b940a40d..edb2ab8b70 100644
--- a/src/scheduler/fragment_context.cpp
+++ b/src/scheduler/fragment_context.cpp
@@ -1100,10 +1100,10 @@ void FragmentContext::MakeSinkState(i64 parallel_count) {
             break;
         }
         case PhysicalOperatorType::kLimit: {
-            if (fragment_type_ != FragmentType::kParallelStream) {
-                String error_message = fmt::format("{} should in parallel stream fragment", PhysicalOperatorToString(last_operator->operator_type()));
-                UnrecoverableError(error_message);
-            }
+            // if (fragment_type_ != FragmentType::kParallelStream) {
+            //     String error_message = fmt::format("{} should in parallel stream fragment", PhysicalOperatorToString(last_operator->operator_type()));
+            //     UnrecoverableError(error_message);
+            // }
 
             if ((i64)tasks_.size() != parallel_count) {
                 String error_message = fmt::format("{} task count isn't correct.", PhysicalOperatorToString(last_operator->operator_type()));
diff --git a/test/sql/dql/knn/embedding/test_knn_hnsw_l2.slt b/test/sql/dql/knn/embedding/test_knn_hnsw_l2.slt
index 0214a4512c..a0a1a44052 100644
--- a/test/sql/dql/knn/embedding/test_knn_hnsw_l2.slt
+++ b/test/sql/dql/knn/embedding/test_knn_hnsw_l2.slt
@@ -60,5 +60,11 @@ SELECT c1 FROM test_knn_hnsw_l2 SEARCH MATCH VECTOR (c2, [0.3, 0.3, 0.2, 0.2], '
 8
 8
 
+query I
+SELECT c1 FROM test_knn_hnsw_l2 SEARCH MATCH VECTOR (c2, [0.3, 0.3, 0.2, 0.2], 'float', 'l2', 3) WITH (ef = 4) LIMIT 2;
+----
+8
+8
+
 statement ok
 DROP TABLE test_knn_hnsw_l2;
\ No newline at end of file