fix encoding

Signed-off-by: Bugen Zhao <i@bugenzhao.com>
risingwavelabs · Mar 7, 2023 · 7fcfeb3 · 7fcfeb3
1 parent 966d290
commit 7fcfeb3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/src/common/src/util/value_encoding/column_aware_row_encoding.rs b/src/common/src/util/value_encoding/column_aware_row_encoding.rs
@@ -75,13 +75,13 @@ impl RowEncoding {
                 self.flag |= Flag::OFFSET16;
                 usize_offsets
                     .iter()
-                    .for_each(|m| self.offsets.put_u16(*m as u16));
+                    .for_each(|m| self.offsets.put_u16_le(*m as u16));
             }
             _n @ ..=const { u32::MAX as usize } => {
                 self.flag |= Flag::OFFSET32;
                 usize_offsets
                     .iter()
-                    .for_each(|m| self.offsets.put_u32(*m as u32));
+                    .for_each(|m| self.offsets.put_u32_le(*m as u32));
             }
             _ => unreachable!("encoding length exceeds u32"),
         }

diff --git a/src/meta/src/stream/stream_graph/fragment.rs b/src/meta/src/stream/stream_graph/fragment.rs
@@ -21,9 +21,7 @@ use anyhow::Context;
 use enum_as_inner::EnumAsInner;
 use itertools::Itertools;
 use risingwave_common::bail;
-use risingwave_common::catalog::{
-    generate_internal_table_name_with_type, TableId, INITIAL_TABLE_VERSION_ID,
-};
+use risingwave_common::catalog::{generate_internal_table_name_with_type, TableId};
 use risingwave_pb::catalog::Table;
 use risingwave_pb::meta::table_fragments::fragment::FragmentDistributionType;
 use risingwave_pb::meta::table_fragments::Fragment;