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

[季 鸿飞]

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

此致


敬礼


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

[季 鸿飞]

Hi:大家好！

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

感谢大家！



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



________________________________
发件人: 季 鸿飞 <[hidden email]>
发送时间: Monday, June 17, 2019 9:40:54 PM
收件人: [hidden email]
主题: 关于在Flink-process中调用其他系统API的问题

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

此致


敬礼


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