File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
flink-core/src/main/java/org/apache/flink/api/connector/source Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change 2222
2323/**
2424 * A decorative interface for {@link Source}. Implementing this interface indicates that the source
25- * operator needs to report splits to the enumerator and receive reassignment.
25+ * operator needs to report splits to the enumerator on start up and receive reassignment on
26+ * recovery.
2627 */
2728@ PublicEvolving
2829public interface SupportsSplitReassignmentOnRecovery {}
Original file line number Diff line number Diff line change @@ -1910,7 +1910,7 @@ under the License.
19101910 <configuration >
19111911 <rules >
19121912 <requireMavenVersion >
1913- <version >3.8.6</version >
1913+ <version >[ 3.8.6] </version >
19141914 </requireMavenVersion >
19151915 <requireJavaVersion >
19161916 <version >${target.java.version} </version >
You can’t perform that action at this time.
0 commit comments