Skip to content

Commit 1a9ef0a

Browse files
committed
re-add suggestions for dynamic/json
1 parent 234fdfd commit 1a9ef0a

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

lib/column/dynamic.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -317,7 +317,9 @@ func (c *Dynamic) decodeHeader(reader *proto.Reader) error {
317317
return fmt.Errorf("failed to read dynamic serialization version: %w", err)
318318
}
319319

320-
if dynamicSerializationVersion != SupportedDynamicSerializationVersion {
320+
if dynamicSerializationVersion == DeprecatedDynamicSerializationVersion {
321+
return fmt.Errorf("deprecated dynamic serialization version: %d, enable \"output_format_native_use_flattened_dynamic_and_json_serialization\" in your settings", dynamicSerializationVersion)
322+
} else if dynamicSerializationVersion != SupportedDynamicSerializationVersion {
321323
return fmt.Errorf("unsupported dynamic serialization version: %d", dynamicSerializationVersion)
322324
}
323325

lib/column/json.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -711,6 +711,8 @@ func (c *JSON) ReadStatePrefix(reader *proto.Reader) error {
711711
c.serializationVersion = jsonSerializationVersion
712712

713713
switch jsonSerializationVersion {
714+
case JSONDeprecatedObjectSerializationVersion:
715+
return fmt.Errorf("deprecated json serialization version: %d, enable \"output_format_native_use_flattened_dynamic_and_json_serialization\" in your settings", jsonSerializationVersion)
714716
case JSONObjectSerializationVersion:
715717
err := c.decodeObjectHeader(reader)
716718
if err != nil {

0 commit comments

Comments
 (0)