From 9e1ca8d1048a7187a2d5d2e74fc621aad4c85b59 Mon Sep 17 00:00:00 2001
From: Sutou Kouhei <kou@clear-code.com>
Date: Thu, 29 Jun 2023 14:32:36 +0900
Subject: [PATCH] Fix a typo

---
 cpp/src/arrow/ipc/reader.cc | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/cpp/src/arrow/ipc/reader.cc b/cpp/src/arrow/ipc/reader.cc
index 76df1cb20d34d..6a5ab4598e72d 100644
--- a/cpp/src/arrow/ipc/reader.cc
+++ b/cpp/src/arrow/ipc/reader.cc
@@ -916,7 +916,7 @@ class StreamDecoderInternal : public MessageDecoderListener {
                                       &out_schema_, &field_inclusion_mask_,
                                       &swap_endian_));
 
-    num_required_initial_dictionaries_ = dictionary_memo_.fields().num_fields();
+    num_required_initial_dictionaries_ = dictionary_memo_.fields().num_dicts();
     num_read_initial_dictionaries_ = 0;
     if (num_required_initial_dictionaries_ == 0) {
       state_ = State::RECORD_BATCHES;
@@ -930,7 +930,7 @@ class StreamDecoderInternal : public MessageDecoderListener {
   Status OnInitialDictionaryMessageDecoded(std::unique_ptr<Message> message) {
     if (message->type() != MessageType::DICTIONARY_BATCH) {
       return Status::Invalid("IPC stream did not have the expected number (",
-                             dictionary_memo_.fields().num_fields(),
+                             num_required_initial_dictionaries_,
                              ") of dictionaries at the start of the stream");
     }
     RETURN_NOT_OK(ReadDictionary(*message));