我们使用异步IO操作符来调用外部API。到目前为止，我们每个事件只有一个api调用。但是，我们有一个要求，我们必须为每个事件引入多个API调用。在操作符中使用线程并在一系列调用中进行调用确实提供了一个解决方案，但这是否违背了使用异步IO的目的？使用线程会导致任何其他问题吗？
浏览 28提问于2020-02-04得票数 2
回答已采纳
1回答
接收器的invoke方法似乎没有办法做异步？例如返回Future我知道flink有异步api，但它似乎不适用于接收器impl？
浏览 6提问于2017-12-08得票数 2
回答已采纳
2回答
我目前正在使用Apache并在其中使用RxJava，我的问题是:使用这两种方法都是合适的吗？因为我的flink操作总是映射函数，并且在其中我更多地使用Rx，比如从flink获取元组并对它们进行异步操作(转到DB、写入队列等等)，但是我最终没有使用flink向我公开的大多数方法，当Rxjava随着处理结束时，我的程序步骤返回json。你能告诉我，这是一个正确的使用flink，或如果有aa更好的
浏览 4提问于2016-06-10得票数 1
回答已采纳
我有一个usecase，我在flink中使用带有普通映射器的异步IO操作符。我正在使用flink 1.8。因此，异步操作符必须位于操作符链的首位。我的操作符流看起来是这样的：由于异步操作符是头的</e
浏览 5提问于2021-03-05得票数 0
回答已采纳
1回答
是否可以在apache代码中调用外部api (RESTful)。如果有可能的话，那我们该怎么做呢？我从简单的java代码调用一个api，它运行良好，但是当我在apache中使用相同的代码时，它会抛出一个异常：
java.io.IOException: Server returned HTTP response
浏览 1提问于2018-04-27得票数 2
当我试图用flatMap操作符写出集合时，我得到了非法的状态异常(仅在高负载下)：缓冲池被破坏了，我在这里做错了什么？当flink抛出缓冲池错误时？(BufferBuilder.java:79) at o
浏览 1提问于2019-04-02得票数 3
回答已采纳
我们正在与flink一起进行异步IO调用。很多时候，IO调用是重复的(相同的参数集)，我们调用的大约80%的API对相同的参数返回相同的响应。所以，我们不想再打电话了。我们认为我们可以使用状态来存储先前的响应并再次使用它们。问题是，尽管我们的响应可以再次使用，但此类响应的数量很大，因此需要大量
浏览 7提问于2020-02-03得票数 2
回答已采纳
大家好，我们有一个带蓝绿色部署的Flink应用程序，我们使用Flink运算符获得它。 sub_filter '<head>
浏览 28提问于2022-02-04得票数 1
回答已采纳
我很想知道用于外部数据访问的Asynchronous I/O Flink API是否也适用于Beam。我找不到任何具体的东西。我知道横梁使用Flink作为执行框架，所以异步I/O对横梁也是可能的，但我不确定API是否已经定义。
浏览 18提问于2021-10-06得票数 0
谁能给我指引一条正确的路？ at org.apache.flink.runtime.io.network.api.writer.RecordWriter.sendToTarget(RecordWriter.java:131) ~[flink-dist_2.11-1.2.0.jar:1.2.0]
浏览 8提问于2018-01-16得票数 4
我正在学习Flink，我想构建一个扩展ProcessWindowFunction的操作符函数，并用一个参数作为类的字段值来重载一个新的构造函数，但是当这个类被实例化时，如果没有这个字段，我就会感到困惑。.PoJoElecMeterSource;import org.apache.flink.streaming.api.
浏览 25提问于2020-05-09得票数 0
回答已采纳
我们正在使用Flink 1.8.0，并在EMR 上运行它，并希望测量吞吐量。，因为我们的操作符是链式的，所以我们在代码中添加了计时器和计数器--本质上是一个异步操作符，它使API调用同时作为源和同步。在应用程序母版(即Flink的web用户界面)中，我们能够获得计数器的值，但不能得到仪表的值.。，我们显然需要所有任务管理器的吞吐量。使用仪表，我们能够得到单个任务管
浏览 3提问于2020-01-16得票数 1
回答已采纳
我需要让一个AsyncIO富函数根据最新的规则集执行调用。对于像map这样的操作，我能够通过关注这篇博客文章来处理具有丰富功能的BroadcastConnectedStream：https://flink.apache.org/2019/06/26/broadcast-state.html/api/java/index.html?org/apache/flink
浏览 29提问于2020-06-19得票数 0
回答已采纳
1回答
我正在使用flink siddhi并在处理大型对象时走出内存错误。在siddhi生成的输出流中，我有超过200个字段的对象，之后我有一些操作符来处理这个对象。flink版本1.7.2 at com.esotericsoftware.kryo.io.Input.readBytes(DefaultOperatorStateBackend.java:62)
at org.apache.<em
浏览 12提问于2021-12-09得票数 0
我们使用的是Flink 1.2.0和建议的S3AFileSystem配置。当一个简单的流作业的源是一个S3桶中的一个文件夹时，它就会像预期的那样工作。如果作业的源是包含子文件夹的文件夹，那么作业运行时不会出现错误--但是而不是会产生输出。 interval = Time.seconds(10
浏览 12提问于2017-04-27得票数 3
回答已采纳
我正在尝试修改保存在S3上的现有保存点，该保存点是用flink 1.12.2 & ververica 2.4.1创建的。我所采取的步骤如下：
machine;Opened 将包含'_metadata‘和savepoint文件的保存点从S3复制到本地S3 flink状态，并读取我感兴趣的操作符的状态；创建并修改了我希望用它替换操作符状态的数据集，然后手动将该保存点移动到S3，以便<e
浏览 3提问于2021-08-25得票数 1
回答已采纳
我有几个Flink作业，它们接收来自一系列Kafka主题的数据，进行一些聚合，并将结果发布到Kafka主题中。
聚合部分在某种程度上是困难的。我必须从几个HTTP端点检索一些信息，并以特定的格式将响应放在一起。问题是有些出站HTTP调用有时会超时，所以我需要一种重试它们的方法。我想知道是否有一种规范的方法在Flink操作符中完成这样的任务，而不需要完全手工地做一些事情。如果没有，建议采取什么办法？
浏览 7提问于2022-08-17得票数 0
回答已采纳
让我们假设Flink每秒接收1000条tweet流，在这个过程中的某个地方，它需要将它们分类为垃圾邮件或非垃圾邮件。我有一个由20台机器组成的集群，它们通过REST API提供“分类”微服务，它们可以提供每秒10k tweet的最大吞吐量，并且它们的延迟是3秒。，我猜Flink除了启动30k线程之外别无选择，这可能是不好的。我在源代码中看到Flink使用Netty，我猜它可以通过使用异步调用来更有效
浏览 16提问于2016-08-07得票数 2
回答已采纳
我正在apache flink中做一个项目，我需要调用多个API来实现我的目标。每个API的结果是下一个API工作所必需的。同样，由于我在KeyedStream上这样做，相同的流将同时适用于多个数据。 /------API1---API2----
KeyedStream ----|------<
浏览 0提问于2019-05-02得票数 1
假设我的Flink工作收到了一系列股票价格(举个例子)，如果某只股票跌破了一定的价格，我们就会发出警告。用户可以添加或删除这些警报条件。我的Flink作业如何以可伸缩的方式动态跟踪所有这些警报条件？我可以创建一个API，我的Flink作业可以调用这个API来获取所有更新的警报标准，但这意味着要多次调用API以保持每件事情都是最新
浏览 4提问于2021-02-02得票数 0
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
