fix

Author: lucasfang

src/paimon/core/operation/commit/commit_changes_provider.cpp

@@ -27,12 +27,10 @@ class FixedInputCommitChangesProvider final : public CommitChangesProvider {
     FixedInputCommitChangesProvider(std::vector<ManifestEntry> delta_files,
                                     std::vector<ManifestEntry> changelog_files,
                                     std::vector<IndexManifestEntry> index_entries)
-        : commit_changes_(std::make_shared<CommitChanges>(std::move(delta_files),
-                                                          std::move(changelog_files),
-                                                          std::move(index_entries))) {}
+        : commit_changes_(std::make_shared<CommitChanges>(
+              std::move(delta_files), std::move(changelog_files), std::move(index_entries))) {}
 
-    Result<std::shared_ptr<CommitChanges>> Provide(
-        const std::optional<Snapshot>&) const override {
+    Result<std::shared_ptr<CommitChanges>> Provide(const std::optional<Snapshot>&) const override {
         return commit_changes_;
     }
 

src/paimon/core/operation/commit/commit_changes_provider.h

@@ -48,8 +48,7 @@ class CommitChangesProvider {
     virtual ~CommitChangesProvider() = default;
 
     static std::shared_ptr<CommitChangesProvider> Provider(
-        std::vector<ManifestEntry> delta_files,
-        std::vector<ManifestEntry> changelog_files,
+        std::vector<ManifestEntry> delta_files, std::vector<ManifestEntry> changelog_files,
         std::vector<IndexManifestEntry> index_entries);
 
     virtual Result<std::shared_ptr<CommitChanges>> Provide(

src/paimon/core/operation/commit/commit_scanner.cpp

@@ -109,8 +109,7 @@ Result<std::vector<ManifestEntry>> CommitScanner::ReadAllEntriesFromPartitions(
 }
 
 Result<std::unique_ptr<FileStoreScan>> CommitScanner::NewScan(
-    const std::vector<std::map<std::string, std::string>>& partitions,
-    bool for_overwrite) const {
+    const std::vector<std::map<std::string, std::string>>& partitions, bool for_overwrite) const {
     auto scan_filter = std::make_shared<ScanFilter>(/*predicate=*/nullptr, partitions,
                                                     /*bucket_filter=*/std::nullopt);
     if (!scan_supplier_) {
@@ -175,10 +174,9 @@ std::shared_ptr<CommitChangesProvider> CommitScanner::OverwriteChangesProvider(
         [this, partitions](const Snapshot& snapshot) -> Result<std::vector<ManifestEntry>> {
             PAIMON_ASSIGN_OR_RAISE(std::unique_ptr<FileStoreScan> scan,
                                    NewScan(partitions, /*for_overwrite=*/true));
-            PAIMON_ASSIGN_OR_RAISE(std::shared_ptr<FileStoreScan::RawPlan> plan,
-                                   scan->WithSnapshot(snapshot)
-                                       ->WithKind(ScanMode::ALL)
-                                       ->CreatePlan());
+            PAIMON_ASSIGN_OR_RAISE(
+                std::shared_ptr<FileStoreScan::RawPlan> plan,
+                scan->WithSnapshot(snapshot)->WithKind(ScanMode::ALL)->CreatePlan());
             return plan->Files();
         },
         [this, partitions](const Snapshot& snapshot) {

src/paimon/core/operation/commit/overwrite_changes_provider.cpp

@@ -24,9 +24,9 @@
 
 namespace paimon {
 
-OverwriteChangesProvider::OverwriteChangesProvider(
-    std::vector<ManifestEntry> changes, std::vector<IndexManifestEntry> index_entries,
-    ManifestScan manifest_scan, IndexScan index_scan)
+OverwriteChangesProvider::OverwriteChangesProvider(std::vector<ManifestEntry> changes,
+                                                   std::vector<IndexManifestEntry> index_entries,
+                                                   ManifestScan manifest_scan, IndexScan index_scan)
     : changes_(std::move(changes)),
       index_entries_(std::move(index_entries)),
       manifest_scan_(std::move(manifest_scan)),
@@ -51,7 +51,7 @@ Result<std::shared_ptr<CommitChanges>> OverwriteChangesProvider::Provide(
     for (const auto& entry : entries) {
         existing_identifiers.insert(entry.CreateIdentifier());
         delta_files.emplace_back(FileKind::Delete(), entry.Partition(), entry.Bucket(),
-                     entry.TotalBuckets(), entry.File());
+                                 entry.TotalBuckets(), entry.File());
     }
 
     for (const auto& change : changes_) {

src/paimon/core/operation/commit/overwrite_changes_provider_test.cpp

@@ -200,9 +200,8 @@ TEST(OverwriteChangesProviderTest, TestProvidePropagatesScanErrors) {
             return std::vector<IndexManifestEntry>{};
         });
 
-    ASSERT_NOK_WITH_MSG(
-        provider_manifest_fail.Provide(std::optional<Snapshot>(MakeSnapshot())),
-        "manifest scan failed");
+    ASSERT_NOK_WITH_MSG(provider_manifest_fail.Provide(std::optional<Snapshot>(MakeSnapshot())),
+                        "manifest scan failed");
 
     OverwriteChangesProvider provider_index_fail(
         changes, index_entries,
@@ -213,9 +212,8 @@ TEST(OverwriteChangesProviderTest, TestProvidePropagatesScanErrors) {
             return Status::Invalid("index scan failed");
         });
 
-    ASSERT_NOK_WITH_MSG(
-        provider_index_fail.Provide(std::optional<Snapshot>(MakeSnapshot())),
-        "index scan failed");
+    ASSERT_NOK_WITH_MSG(provider_index_fail.Provide(std::optional<Snapshot>(MakeSnapshot())),
+                        "index scan failed");
 }
 
 }  // namespace paimon::test