You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@seatunnel.apache.org by "CheneyYin (via GitHub)" <gi...@apache.org> on 2023/04/23 10:01:23 UTC

[GitHub] [incubator-seatunnel] CheneyYin commented on issue #4648: [Bug] [spark] only support one sinkPlugin

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就可以正常执行，这个是否需要修复一下呢
   > ![image](https://user-images.githubusercontent.com/46857527/233831257-e03b4949-6741-4d17-a803-cdea88e94c88.png)
   > 
   > ![image](https://user-images.githubusercontent.com/46857527/233831217-175b527c-2d28-4679-8f23-457e85e1c5fc.png)
   > 
   
   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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org