CheneyYin commented on issue #4648: URL: https://github.com/apache/incubator-seatunnel/issues/4648#issuecomment-1519019329
> read 自定义SeaTunnelSource,自定义kafkareader里面控制了当模式为stream的时候,永远不结束读取数据,因为read模式是批处理模式,readStream才是流处理,所以第一个sinkPlugin 永远不会结束,我试过发送signalNoMoreElement 的时候多个sinkPlugins就可以正常执行,这个是否需要修复一下呢 >  > >  > Similar to #4640 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
