starrocks 用官网给出的 csv 例子 sink 端一直在 INITIALIZING

[yuxuan-luo]

用的这个 examples：https://github.com/StarRocks/starrocks-connector-for-apache-flink/blob/main/examples/src/main/java/com/starrocks/connector/flink/examples/datastream/LoadCustomJavaRecords.java

2024-07-31 15:22:17.211 [Sink: Unnamed (2/2)#0] INFO org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend [] - Using predefined options: DEFAULT.
2024-07-31 15:22:17.211 [Sink: Unnamed (2/2)#0] INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - Using application-defined state backend: EmbeddedRocksDBStateBackend{, localRocksDbDirectories=[/data/rocksdb], enableIncrementalCheckpointing=TRUE, numberOfTransferThreads=4, writeBatchSize=2097152}
2024-07-31 15:22:17.212 [Sink: Unnamed (2/2)#0] INFO org.apache.flink.runtime.state.StateBackendLoader [] - State backend loader loads the state backend as EmbeddedRocksDBStateBackend
2024-07-31 15:22:17.267 [Sink: Unnamed (2/2)#0] INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - Using job/cluster config to configure application-defined checkpoint storage: org.apache.flink.runtime.state.storage.FileSystemCheckpointStorage@59882121
2024-07-31 15:22:17.280 [Sink: Unnamed (2/2)#0] INFO org.apache.flink.runtime.taskmanager.Task [] - Sink: Unnamed (2/2)#0 (f06378184db6180160b3dc7e062cf937_0a448493b4782967b150582570326227_1_0) switched from DEPLOYING to INITIALIZING.
2024-07-31 15:22:17.478 [Sink: Unnamed (2/2)#0] INFO com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2 [] - Initialize state
2024-07-31 15:22:17.542 [Sink: Unnamed (2/2)#0] INFO com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2 [] - Close sink function
2024-07-31 15:22:17.542 [Sink: Unnamed (2/2)#0] INFO com.starrocks.data.load.stream.v2.StreamLoadManagerV2 [] - Stream load manager flush