...

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

The goal of this FLIP is to add additional fields to Sink#InitContext to expose ExecutionConfig, or at least the ExecutionConfig#isObjectReuseEnabled.

This is necessary to migrate the current JdbcSink to the SinkV2 (FLIP-239 -> FLINK-25421) more specifically in order to be able to reuse the JdbcOutputFormat which today uses RuntimeContext to get the ExecutionConfig#isObjectReuseEnabled. 

Public Interfaces

• We want to extend the Sink#InitContext to provide the ExecutionConfig.

Proposed Changes

We propose to expose the ExecutionConfig, so that all configs on this will be available, but we could only expose the isObjectReuse if we want to expose only the required configuration.

@PublicEvolving
public interface Sink<InputT> extends Serializable {
    ... current methods
 
    @PublicEvolving
    public interface InitContext {
        ... current methods

		/**	
    	 * Returns the {@link org.apache.flink.api.common.ExecutionConfig} for the currently executing
    	 * job.
    	 */
        ExecutionConfig getExecutionConfig();
    }
}  

Compatibility, Deprecation, and Migration Plan

• The change only one additional method so no impact on existing code.

Test Plan

These simple API changes will be covered by extending unit and integration tests.

Rejected Alternatives

INo alternatives yet.