是否可以在apache flink代码中调用外部api（restful）。如果可能的话，那我们怎么做呢。
我从简单的java代码中调用api，它工作正常，但是当我在apache flink中使用相同的代码时，它抛出了一个异常：
java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi是否可以在apache flink代码中调用外部api（restful）。如果可能的话，那我们怎么做呢。
我从简单的java代码中调用api，它工作正常，但是当我在apache flink中使用相同的代码时，它抛出了一个异常：
java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi
1条答案
按热度按时间46qrfjad1#
是否可以在apache flink代码中调用外部api（restful）。如果可能的话，那我们怎么做呢。
您可以使用flink流api中提供的异步i/o功能。flink的异步i/o api允许用户将异步请求客户机用于数据流。更多细节和例子在这里。
java.io.ioexception:服务器返回url的http响应代码：500:http://example.com/someapi
这似乎不是flink的错误，因为响应是500。检查正在发送的请求头/参数，并验证是否正确创建了http请求。尝试一些实用程序，比如postman，首先测试api。