Hello everyone, I am reading data from Flink Datastream using Kafka (reading from multiple streams), then i am converting those streams in to temporary View using flink SQL and perform join operations. For join operations also, i am using Flink SQL. The problem I am facing is when i am adding new field in flink sql query, and then trying to migrate savepoint, I am having this error:

Caused by: org.apache.flink.util.StateMigrationException: The new state serializer (org.apache.flink.api.common.typeutils.base.MapSerializer@58eac6c9) must not be incompatible with the old state serializer (org.apache.flink.api.common.typeutils.base.MapSerializer@a56de33a).

Note: When I checked, this error is coming when i changed the query and not the pojo of the datastream.

You can't evolve a Flink SQL query

Is there any wayaround then?

Restart your application without state

ok thanks