fix

Author: lucasfang

src/paimon/core/manifest/manifest_committable_test.cpp

@@ -92,8 +92,7 @@ TEST_F(ManifestCommittableTest, TestSimple) {
             GetCommitMessages(paimon::test::GetDataDir() +
                                   "/orc/append_09.db/append_09/commit_messages/commit_messages-01",
                               /*version=*/3);
-        ManifestCommittable committable(/*identifier=*/123, /*watermark=*/456,
-                                        properties, msgs);
+        ManifestCommittable committable(/*identifier=*/123, /*watermark=*/456, properties, msgs);
         ASSERT_EQ(committable.Properties(), properties);
         ASSERT_TRUE(IsEqualMsgs(msgs, committable.FileCommittables()));
     }

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

@@ -24,9 +24,7 @@ StaticCommitChangesProvider::StaticCommitChangesProvider(
     const std::vector<ManifestEntry>& delta_files,
     const std::vector<ManifestEntry>& changelog_files,
     const std::vector<IndexManifestEntry>& index_entries)
-    : delta_files_(delta_files),
-      changelog_files_(changelog_files),
-      index_entries_(index_entries) {}
+    : delta_files_(delta_files), changelog_files_(changelog_files), index_entries_(index_entries) {}
 
 Status StaticCommitChangesProvider::Provide(const std::optional<Snapshot>&,
                                             std::vector<ManifestEntry>* delta_files,

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

@@ -53,7 +53,7 @@ CommitScanner::CommitScanner(const std::shared_ptr<SnapshotManager>& snapshot_ma
       schema_manager_(schema_manager),
       manifest_list_(manifest_list),
       manifest_file_(manifest_file),
-    index_manifest_file_(index_manifest_file),
+      index_manifest_file_(index_manifest_file),
       table_schema_(table_schema),
       schema_(schema),
       core_options_(core_options),
@@ -132,7 +132,7 @@ Result<std::vector<IndexManifestEntry>> CommitScanner::ReadAllIndexEntriesFromPa
 
         std::vector<std::pair<std::string, std::string>> part_values;
         PAIMON_ASSIGN_OR_RAISE(part_values,
-                       partition_computer_->GeneratePartitionVector(entry.partition));
+                               partition_computer_->GeneratePartitionVector(entry.partition));
         std::map<std::string, std::string> partition;
         for (const auto& [key, value] : part_values) {
             partition[key] = value;
@@ -154,8 +154,8 @@ Result<std::vector<IndexManifestEntry>> CommitScanner::ReadAllIndexEntriesFromPa
         return false;
     };
 
-    PAIMON_RETURN_NOT_OK(index_manifest_file_->Read(snapshot.IndexManifest().value(), filter,
-                                                    &index_entries));
+    PAIMON_RETURN_NOT_OK(
+        index_manifest_file_->Read(snapshot.IndexManifest().value(), filter, &index_entries));
     return index_entries;
 }
 

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

@@ -25,9 +25,8 @@
 namespace paimon {
 
 OverwriteChangesProvider::OverwriteChangesProvider(
-    const std::vector<ManifestEntry>& changes,
-    const std::vector<IndexManifestEntry>& index_entries, ManifestScan manifest_scan,
-    IndexScan index_scan)
+    const std::vector<ManifestEntry>& changes, const std::vector<IndexManifestEntry>& index_entries,
+    ManifestScan manifest_scan, IndexScan index_scan)
     : changes_(changes),
       index_entries_(index_entries),
       manifest_scan_(std::move(manifest_scan)),

src/paimon/core/operation/file_store_commit_impl.cpp

@@ -129,9 +129,9 @@ FileStoreCommitImpl::FileStoreCommitImpl(
       num_bucket_(options.GetBucket()),
       bucket_mode_(ResolveBucketMode(options.GetBucket(), table_schema)),
       table_schema_(table_schema),
-    commit_scanner_(snapshot_manager, schema_manager, manifest_list, manifest_file,
-                index_manifest_file, table_schema, schema, options, executor, pool,
-                partition_computer_.get(), std::move(scan_supplier)),
+      commit_scanner_(snapshot_manager, schema_manager, manifest_list, manifest_file,
+                      index_manifest_file, table_schema, schema, options, executor, pool,
+                      partition_computer_.get(), std::move(scan_supplier)),
       conflict_detection_(table_schema, options, snapshot_manager_, manifest_list, manifest_file),
       manifest_file_(manifest_file),
       manifest_list_(manifest_list),
@@ -448,10 +448,10 @@ Status FileStoreCommitImpl::ExecuteOverwrite(
     }
 
     if (!skip_overwrite) {
-        PAIMON_ASSIGN_OR_RAISE(int32_t cnt,
-                               TryOverwrite(overwrite_partitions, changes->append_table_files,
-                                            changes->append_index_files, identifier, watermark,
-                                            properties));
+        PAIMON_ASSIGN_OR_RAISE(
+            int32_t cnt,
+            TryOverwrite(overwrite_partitions, changes->append_table_files,
+                         changes->append_index_files, identifier, watermark, properties));
         *attempt += cnt;
         *generated_snapshot += 1;
     }
@@ -482,8 +482,7 @@ Result<std::vector<ManifestEntry>> FileStoreCommitImpl::GetAllFiles(
 Result<std::map<std::string, std::string>> FileStoreCommitImpl::PartitionToMap(
     const BinaryRow& partition) const {
     std::vector<std::pair<std::string, std::string>> part_values;
-    PAIMON_ASSIGN_OR_RAISE(part_values,
-                           partition_computer_->GeneratePartitionVector(partition));
+    PAIMON_ASSIGN_OR_RAISE(part_values, partition_computer_->GeneratePartitionVector(partition));
     std::map<std::string, std::string> partition_map;
     for (const auto& [key, value] : part_values) {
         partition_map[key] = value;
@@ -649,9 +648,8 @@ Result<int32_t> FileStoreCommitImpl::TryCommit(const std::vector<ManifestEntry>&
 
 Result<int32_t> FileStoreCommitImpl::TryCommit(
     const std::shared_ptr<CommitChangesProvider>& changes_provider, int64_t identifier,
-    std::optional<int64_t> watermark,
-    const std::map<std::string, std::string>& properties, Snapshot::CommitKind commit_kind,
-    bool detect_conflicts) {
+    std::optional<int64_t> watermark, const std::map<std::string, std::string>& properties,
+    Snapshot::CommitKind commit_kind, bool detect_conflicts) {
     conflict_detection_.SetRowIdCheckFromSnapshot(std::nullopt);
     int32_t retry_count = 0;
     int64_t start_millis = DateTimeUtils::GetCurrentUTCTimeUs() / 1000;

src/paimon/core/operation/file_store_commit_impl.h

@@ -136,8 +136,7 @@ class FileStoreCommitImpl : public FileStoreCommit {
     Result<int32_t> TryOverwrite(const std::vector<std::map<std::string, std::string>>& partition,
                                  const std::vector<ManifestEntry>& changes,
                                  const std::vector<IndexManifestEntry>& index_entries,
-                                 int64_t commit_identifier,
-                                 std::optional<int64_t> watermark,
+                                 int64_t commit_identifier, std::optional<int64_t> watermark,
                                  const std::map<std::string, std::string>& properties);
 
     Status ExecuteOverwrite(const std::vector<std::map<std::string, std::string>>& partitions,