LiXiaoPing
LiXiaoPing
fix: 完善测试用例
refactor: 拆分测试用例
refactor: 拆分成独立的测试用例
依据条件(log.isInfoEnabled)输出日志
拆分成两个独立的测试用例
只要表名是纯英文,其它保持不变,则数据同步一切正常,如果将表名改为中文名,作业能正常启动,但在sink端check point 启动事务时因抛出异常导致数据不能同步。 ```sh java.io.IOException: Could not perform checkpoint 16 for operator SourceConversion(table=[Unregistered_DataStream_91], fields=[姓名, 总分数]) -> NotNullEnforcer(fields=[姓名, 总分数]) -> Sink: Sink(table=[default_catalog.default_database.学生分数_9], fields=[姓名, 总分数]) (1/1)#12. at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1271) at org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:147) at org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler.triggerCheckpoint(SingleCheckpointBarrierHandler.java:287)...