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

Posted to user-zh@flink.apache.org by 季鸿飞 <wi...@live.cn> on 2019/06/17 13:40:54 UTC

关于在Flink-process中调用其他系统API的问题

大家好：
我在Broadcast广播流，单机模式下（idea运行）：
connect().process(new function)方法中向其他业务系统请求数据，debug时发现，代码运行到请求数据那行的时候就不再往下运行了，就算参数错误也不会报错。
新的数据流进来也是阻塞在了那行代码那。
我在单独的Test.java 中是可行的，参数错误也会直接报错。
希望得到大家的帮助。

此致


敬礼


发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用

答复: 关于在Flink-process中调用其他系统API的问题

Posted by 季鸿飞 <wi...@live.cn>.

Hi:大家好！

       关于在Flink-process中调用其他系统API的问题，已解决！

感谢大家！



发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用



________________________________
发件人: 季 鸿飞 <wi...@live.cn>
发送时间: Monday, June 17, 2019 9:40:54 PM
收件人: user-zh@flink.apache.org
主题: 关于在Flink-process中调用其他系统API的问题

大家好：
我在Broadcast广播流，单机模式下（idea运行）：
connect().process(new function)方法中向其他业务系统请求数据，debug时发现，代码运行到请求数据那行的时候就不再往下运行了，就算参数错误也不会报错。
新的数据流进来也是阻塞在了那行代码那。
我在单独的Test.java 中是可行的，参数错误也会直接报错。
希望得到大家的帮助。

此致


敬礼


发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用