Sergei Morozov

[FLINK-36086] Set isSnapshotCompleted only immediately after snapshot

3

If the SQL Server source connector is restarted while handling updates from a transaction with multiple updates, upon restart, it will skip the non-processed changes and proceed from the next...

| Q | A |------------- | ----------- | Type | deprecation #### Summary Currently, it is impossible to reference a non-existing column in a constraint being added but it's possible...

| Q | A |------------- | ----------- | Type | deprecation The proposed naming is consistent with SQL and with the rest of the `Table::drop*()` method names.

[FLINK-36546] Handle batch sources in DataSinkTranslator

2

There's no public API in Flink to detect the boundedness of a stream, so this patch duplicates the [code](https://github.com/apache/flink/blob/release-1.20.0/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java#L461-L474) from `StreamGraphGenerator` that Flink itself uses to instantiate `CommitterOperatorFactory`.

[FLINK-36407] Shut down coordinatorExecutor upon closing SchemaRegistry

2

See the details in [FLINK-36407](https://issues.apache.org/jira/browse/FLINK-36407). Not sure how this can be unit-tested given that the issue is not reproducible with JUnit.

[FLINK-36406] Close MetadataApplier when the job stops

1

This pull request implements closing `MetadataApplier` when the job stops. This allows `MetadataApplier` implementations to release the resources that they may use to apply schema changes (e.g. a JDBC connection)....