package compat
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
trait
ExplicitUidInOperatorsSupport extends AnyRef
This trait helps to explicitly set uids for Flink's stateful operators.
This trait helps to explicitly set uids for Flink's stateful operators. Regards to https://ci.apache.org/projects/flink/flink-docs-stable/ops/upgrading.html#matching-operator-state operator with state should has specified uid. Otherwise recovery of state could fail.
Currently this class sets up uids by default
You can disable this globally by adding:
globalParameters { explicitUidInStatefulOperators: false }in your model config.
Value Members
- object ExplicitUidInOperatorsSupport