* FIX [parquet] fixed parquet conf error.

Signed-off-by: xinyi-xs <[email protected]>
nanomq · Jan 15, 2025 · cce3247 · cce3247
1 parent f8766b6
commit cce3247
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/include/nng/supplemental/nanolib/conf.h b/include/nng/supplemental/nanolib/conf.h
@@ -352,7 +352,7 @@ struct conf_parquet {
 	char                   *name;
 	char                   *dir;
 	char                   *file_name_prefix;
-	uint8_t                 file_count;
+	uint32_t                 file_count;
 	uint32_t                limit_frequency;
 	uint8_t                 file_index;
 	int32_t                 file_size;

diff --git a/src/supplemental/nanolib/conf_ver2.c b/src/supplemental/nanolib/conf_ver2.c
@@ -1460,6 +1460,8 @@ conf_parquet_parse_ver2(conf *config, conf_exchange_node *node, cJSON *jso)
 			hocon_read_enum(encryption, type,
 			    jso_parquet_encryption, encryption_type);
 		}
+
+		config->parquet.enable = true;
 	} else {
 		// Use the default settings. One should be careful when it's free.
 		node->parquet = &config->parquet;