Hi Xuyang,
Thank you for anticipating my questions and pointing me to the right
resources.
I've requested JIRA account, will create feature request once approved and
then start discussion on dev mailing list.
I am interested in contributing to this feature, would appreciate it if you
can point m
Hi, if the processing logic is modified, then the representation of the
topology would change. Consequently, the UIDs that are determined by the
topological order might change as well, which could potentially cause state
recovery to fail. For further details, you can refer to [1].
Currently, th
Hi Keith,
When you add a new insert statement to your EXECUTE STATEMENT you change
your job graph with independent two graphs.Unfortunately, Flink doesn't
currently provide a way to directly force specific UIDs for operators
through configuration or SQL hints. This is primarily due to how Flink's
Hello,
I'm running into issues restoring from savepoint after changing SQL
statement.
[ERROR] Could not execute SQL statement. Reason:
> java.lang.IllegalStateException: Failed to rollback to
> checkpoint/savepoint
> file:/tmp/flink-savepoints/savepoint-52c344-3bedb8204ff0. Cannot map
> checkpoin
