diff --git a/velox/expression/ComplexViewTypes.h b/velox/expression/ComplexViewTypes.h
index 00a5c8933fc7..2bdee7b4d7df 100644
--- a/velox/expression/ComplexViewTypes.h
+++ b/velox/expression/ComplexViewTypes.h
@@ -1030,13 +1030,14 @@ class RowView
       const RowView& other,
       const CompareFlags flags) const {
     if constexpr (Is < sizeof...(T)) {
-      auto result = std::get<Is>(*childReaders_)
-                        ->baseVector()
-                        ->compare(
-                            std::get<Is>(*other.childReaders_)->baseVector(),
-                            offset_,
-                            other.offset_,
-                            flags);
+      auto result =
+          std::get<Is>(*childReaders_)
+              ->baseVector()
+              ->compare(
+                  std::get<Is>(*other.childReaders_)->baseVector(),
+                  std::get<Is>(*childReaders_)->index(offset_),
+                  std::get<Is>(*other.childReaders_)->index(other.offset_),
+                  flags);
       if (!result.has_value()) {
         return std::nullopt;
       }
diff --git a/velox/expression/VectorReaders.h b/velox/expression/VectorReaders.h
index a35d54d103f2..b042b04c3a33 100644
--- a/velox/expression/VectorReaders.h
+++ b/velox/expression/VectorReaders.h
@@ -52,6 +52,10 @@ struct VectorReader {
   explicit VectorReader(const VectorReader<T>&) = delete;
   VectorReader<T>& operator=(const VectorReader<T>&) = delete;
 
+  vector_size_t index(vector_size_t idx) const {
+    return decoded_.index(idx);
+  }
+
   exec_in_t operator[](size_t offset) const {
     return decoded_.template valueAt<exec_in_t>(offset);
   }
diff --git a/velox/expression/tests/RowViewTest.cpp b/velox/expression/tests/RowViewTest.cpp
index b5310e6a7612..c092080f4cc3 100644
--- a/velox/expression/tests/RowViewTest.cpp
+++ b/velox/expression/tests/RowViewTest.cpp
@@ -205,6 +205,71 @@ class RowViewTest : public functions::test::FunctionBaseTest {
           CompareFlags::NullHandlingMode::kNullAsIndeterminate);
       ASSERT_EQ(l.compare(l, flags), kIndeterminate);
     }
+
+    // Test a layer of indirection with by wrapping the vector in a dictionary
+    {
+      vector_size_t size = 2;
+      auto field1Vector =
+          makeFlatVector<int32_t>(size, [](vector_size_t row) { return row; });
+      auto field2Vector =
+          makeFlatVector<float>(size, [](vector_size_t row) { return row; });
+      auto baseVector = makeRowVector(
+          {field1Vector, field2Vector}, [](vector_size_t idx) { return idx; });
+      BufferPtr indices =
+          AlignedBuffer::allocate<vector_size_t>(size, execCtx_.pool());
+      auto rawIndices = indices->asMutable<vector_size_t>();
+      for (auto i = 0; i < size; ++i) {
+        rawIndices[i] = i;
+      }
+      auto rowVector = wrapInDictionary(indices, size, baseVector);
+      DecodedVector decoded;
+      exec::VectorReader<Row<int32_t, float>> reader(
+          decode(decoded, *rowVector.get()));
+
+      // Test the equals case so that we are traversing all of the tuples and
+      // ensuring correct index accessing.
+      auto l = read(reader, 0);
+      auto r = read(reader, 0);
+      ASSERT_TRUE(l == r);
+    }
+
+    {
+      vector_size_t size = 1;
+      BufferPtr indices =
+          AlignedBuffer::allocate<vector_size_t>(size, execCtx_.pool());
+      auto rawIndices = indices->asMutable<vector_size_t>();
+      for (auto i = 0; i < size; ++i) {
+        rawIndices[i] = i;
+      }
+      DecodedVector decoded1;
+      DecodedVector decoded2;
+      auto wrappedRowVector1 = wrapInDictionary(indices, size, rowVector1);
+      exec::VectorReader<Row<int32_t, float>> reader1(
+          decode(decoded1, *wrappedRowVector1));
+      exec::VectorReader<Row<int32_t, float>> reader2(
+          decode(decoded2, *rowVector2));
+
+      ASSERT_TRUE(reader1.isSet(0));
+      ASSERT_TRUE(reader2.isSet(0));
+      auto l = read(reader1, 0);
+      auto r = read(reader2, 0);
+      // Default flag for all operators other than `==` is kNullAsIndeterminate
+      VELOX_ASSERT_THROW(r < l, "Ordering nulls is not supported");
+      VELOX_ASSERT_THROW(r <= l, "Ordering nulls is not supported");
+      VELOX_ASSERT_THROW(r > l, "Ordering nulls is not supported");
+      VELOX_ASSERT_THROW(r >= l, "Ordering nulls is not supported");
+
+      // Default flag for `==` is kNullAsValue
+      ASSERT_FALSE(r == l);
+
+      // Test we can pass in a flag to change the behavior for compare
+      ASSERT_LT(
+          l.compare(
+              r,
+              CompareFlags::equality(
+                  CompareFlags::NullHandlingMode::kNullAsValue)),
+          0);
+    }
   }
 
   void e2eComparisonTest() {