Skip to content

Retry write when SchemaNotExistException #2192

@loserwang1024

Description

@loserwang1024

Search before asking

  • I searched in the issues and found nothing similar.

Description

Currently, in fluss server

if (schemaIdOfNewData > latestSchemaId || schemaIdOfNewData < 0) {
                        // TODO: we may need to support retriable exception here
                        throw new SchemaNotExistException(
                                "Invalid schema id: "
                                        + schemaIdOfNewData
                                        + ", latest schema id: "
                                        + latestSchemaId);
                    }

If metadata is not sync to tablet server, writer use newer schema to read data, will throw SchemaNotExistException.

Willingness to contribute

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions