单元测试

最近更新时间: 2019-11-11 07:47:04

单元测试可以快速进行作业测试,支持乱序测试、延迟测试2种方式。 读取线下上传的测试数据包中的数据,代替从source中读取数据,并且可以复用画板中source的Schema信息,将测试结果数据输出到开发界面,代替了数据输出到sink。 1、单元测试用于测试数据处理算子的可用性; 2、单元测试需选择指定数据包,数据包在 [资源管理] 中上传; 3、单元测试使用的数据包将复用画布中拖拽的Kafka source的Schema信息; 4、单元测试source算子并行度为1; 5、单元测试结果获取会有一定延迟(每3s获取一次,每次上限100条)。