fix: change full version delta column type for mysql meta backend (#1…

…6583) Co-authored-by: zwang28 <[email protected]>
risingwavelabs · May 6, 2024 · b86ffb2 · b86ffb2
1 parent 222b291
commit b86ffb2
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/meta/model_v2/migration/src/m20231008_020431_hummock.rs b/src/meta/model_v2/migration/src/m20231008_020431_hummock.rs
@@ -30,7 +30,11 @@ impl MigrationTrait for Migration {
                             .not_null()
                             .primary_key(),
                     )
-                    .col(ColumnDef::new(CompactionTask::Task).binary().not_null())
+                    .col(
+                        ColumnDef::new(CompactionTask::Task)
+                            .blob(BlobSize::Long)
+                            .not_null(),
+                    )
                     .col(
                         ColumnDef::new(CompactionTask::ContextId)
                             .integer()
@@ -50,7 +54,7 @@ impl MigrationTrait for Migration {
                             .not_null()
                             .primary_key(),
                     )
-                    .col(ColumnDef::new(CompactionConfig::Config).binary())
+                    .col(ColumnDef::new(CompactionConfig::Config).blob(BlobSize::Long))
                     .to_owned(),
             )
             .await?;
@@ -65,7 +69,7 @@ impl MigrationTrait for Migration {
                             .not_null()
                             .primary_key(),
                     )
-                    .col(ColumnDef::new(CompactionStatus::Status).binary())
+                    .col(ColumnDef::new(CompactionStatus::Status).blob(BlobSize::Long))
                     .to_owned(),
             )
             .await?;
@@ -138,7 +142,7 @@ impl MigrationTrait for Migration {
                             .boolean()
                             .not_null(),
                     )
-                    .col(ColumnDef::new(HummockVersionDelta::FullVersionDelta).binary())
+                    .col(ColumnDef::new(HummockVersionDelta::FullVersionDelta).blob(BlobSize::Long))
                     .to_owned(),
             )
             .await?;