diff --git a/be/src/vec/sink/writer/vhive_table_writer.cpp b/be/src/vec/sink/writer/vhive_table_writer.cpp index 1c123c92b3..4ea5fcbf4e 100644 --- a/be/src/vec/sink/writer/vhive_table_writer.cpp +++ b/be/src/vec/sink/writer/vhive_table_writer.cpp @@ -76,7 +76,6 @@ Status VHiveTableWriter::write(vectorized::Block& block) { writer = _create_partition_writer(block, -1); _partitions_to_writers.insert({"", writer}); RETURN_IF_ERROR(writer->open(_state, _profile)); - RETURN_IF_ERROR(writer->write(block)); } catch (doris::Exception& e) { return e.to_status(); }