pipeline) throws Exception { fakeGenerateRate.acquire(); pipeline.output(fakeRowGenerator.fakeOneRecord(typeInfos)); } @Override public boolean hasMoreElements() { return counter.... 新增ITCase测试用例,然后按照如下流程支持- 通过testcontainer来启动相应的组件![image.png](https://p9-juejin.byteimg.com/tos-cn-i-k3u1fbpfcp/218853f440b54a35aaca6e36ee9e79bb~tplv-k3u1fbpfcp-5.jpe...
pipeline) throws Exception { fakeGenerateRate.acquire(); pipeline.output(fakeRowGenerator.fakeOneRecord(typeInfos)); } ... 新增ITCase测试用例,然后按照如下流程支持* 通过testcontainer来启动相应的组件![picture.image](https://p6-volc-community-sign.byteimg.com/tos-cn-i-tlddhu82om/80a457a3404f482c800aa5af35ce47e4~tplv-...