[flink] Upgrade sink connector to new API version

[michaelkoepf]

Purpose

Linked issue: close #132

Upgrade sink connector from deprecated RichSinkFunction (will be removed in Flink 2.0) to new Sink interface

Tests

• UT (adapted to new implementation, test case logic unchanged): com.alibaba.fluss.connector.flink.sink.FlinkSinkWriterTest.java
• IT (unchanged, because external interface did not change): com.alibaba.fluss.connector.flink.sink.FlinkTableSinkITCase.java

API and Format

n/a

Documentation

n/a

[ChaomingZhangCN]

LGTM, cc @wuchong.

[wuchong]

Sorry for the late reviewing and thanks @michaelkoepf for the contribution. The changes looks good to me in general. Could you rebase the branch to latest main branch to resolve the conflicts?

[michaelkoepf]

@wuchong addressed feedback and rebased, ptal

[wuchong]

Thanks for the updating. LGTM.

[wuchong]

Hi @michaelkoepf , I know why the CI is stuck on FlussDatabaseSyncSourceITCase. It can be easily reproduced in local. The reason is the hard cast here will fail, because we have upgraded from SinkFunctionProvider to SinkV2Provider in this PR, and the cast in this line will fail. So we have to upgrade TestingDatabaseSyncSink to SinkV2 as well. Could you help to fix it?

fluss/fluss-lakehouse/fluss-lakehouse-paimon/src/test/java/com/alibaba/fluss/lakehouse/paimon/testutils/TestingDatabaseSyncSink.java

Lines 92 to 96 in 70229b8

	sinkFunction =
	((SinkFunctionProvider)
	flinkTableSink.getSinkRuntimeProvider(
	new SinkRuntimeProviderContext(false)))
	.createSinkFunction();

[michaelkoepf]

@wuchong i will look into the suggested issue.

[michaelkoepf]

@wuchong fixed

[INFO] Fluss : ............................................ SUCCESS [  1.906 s]
[INFO] Fluss : Test utils ................................. SUCCESS [  3.650 s]
[INFO] Fluss : Common ..................................... SUCCESS [ 15.666 s]
[INFO] Fluss : Metrics : .................................. SUCCESS [  0.077 s]
[INFO] Fluss : Metrics : Prometheus ....................... SUCCESS [  2.893 s]
[INFO] Fluss : Metrics : JMX .............................. SUCCESS [  2.509 s]
[INFO] Fluss : ProtoGen : ................................. SUCCESS [  0.049 s]
[INFO] Fluss : ProtoGen : Generator ....................... SUCCESS [  0.367 s]
[INFO] Fluss : ProtoGen : Maven Plugin .................... SUCCESS [  4.008 s]
[INFO] Fluss : RPC ........................................ SUCCESS [ 19.378 s]
[INFO] Fluss : Server ..................................... SUCCESS [04:28 min]
[INFO] Fluss : Client ..................................... SUCCESS [04:58 min]
[INFO] Fluss : FileSystems : .............................. SUCCESS [  0.053 s]
[INFO] Fluss : FileSystems : Hadoop FS shaded ............. SUCCESS [  3.810 s]
[INFO] Fluss : FileSystems : Hadoop FS .................... SUCCESS [ 20.107 s]
[INFO] Fluss : FileSystems : OSS FS ....................... SUCCESS [ 11.021 s]
[INFO] Fluss : FileSystems : S3 FS ........................ SUCCESS [  7.628 s]
[INFO] Fluss : Connector : ................................ SUCCESS [  0.062 s]
[INFO] Fluss : Connector : Flink .......................... SUCCESS [06:06 min]
[INFO] Fluss : Lakehouse : ................................ SUCCESS [  0.047 s]
[INFO] Fluss : Lakehouse : Paimon ......................... SUCCESS [03:22 min]
[INFO] Fluss : Lakehouse : CLI ............................ SUCCESS [  7.450 s]
[INFO] Fluss : Dist ....................................... SUCCESS [ 12.843 s]

[wuchong]

LGTM.