腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5936)
视频
沙龙
1
回答
使用
Flink
向Cassandra写入记录的不同方法的差异
cassandra
、
apache-flink
我在SO和
Flink
的官方文档上浏览了很多帖子,但是我找不到我想要的东西。我正在寻找RichSinkFunction、
RichAsyncFunction
、AsyncIO和CassandraSink在使用
Flink
在Cassandra DB中编写记录faster/multithreaded因为它打开和关闭连接,所以once.
RichAsyncFunction
-实现与RichSinkFunction一样。它最初在Sync模式下工作。我可以将executorService用于多线程目的。此外,根据其中一个这样的答案,我
浏览 5
提问于2022-01-12
得票数 0
回答已采纳
1
回答
AsyncFunction在KeyedStream上工作吗?
apache-flink
我没找到,所以我在问!是否有在AsyncFunction s上应用KeyedStream?如果是的话,它会保留每把钥匙的订单吗?
浏览 2
提问于2017-12-09
得票数 2
回答已采纳
1
回答
RichAsyncFunction
中的Apache
flink
超时处理
java
、
apache-flink
、
flink-streaming
我使用的是1.5.0版本的
flink
。2- AsyncFunction接口中没有方法超时:)我使用的是AsyncDataStream.unorderedWait,它使用kafka并用
RichAsyncFunction
事实上,所有消息都已读取(正确的偏移量已提交给zookeeper),但并非所有消息都到达
RichAsyncFunction
.asyncInvoke。
浏览 0
提问于2018-07-05
得票数 0
1
回答
如何在Apache
Flink
ui中显示指标?
java
、
apache-flink
运行Apache
Flink
1.8.0。我可以在http://localhost:8081上访问工作的UI。我还验证了我的工作可以在集成开发环境中工作,使用./
flink
run通过命令行提交。我也在我的
RichAsyncFunction
里做了 UI的文档中并不清楚,我们是否需要在
Flink
服务器上启用某些功能?
浏览 32
提问于2019-05-04
得票数 1
1
回答
使用异步I/O从
Flink
调用http REST api
apache-flink
、
flink-streaming
在每次从流中获取数据时,我都必须从
flink
流程元素中获取Rest API中的数据,我如何才能做到这一点,我找不到足够的材料来异步调用Rest服务。请帮我写一些样本文章。
浏览 85
提问于2020-04-28
得票数 0
1
回答
Apache :检查点--在延迟后分派元素的操作符
scala
、
apache-flink
这是
Flink
操作符的代码。class MessageDelayFunction[T](schedulingDelay: Int, timeUnit: TimeUnit) extends
RichAsyncFunction
[T但是,
Flink
的检查点在这个操作符中失败了(我证实没有它它就能正常工作)。检查点每2分钟进行一次,超时时间为10分钟。每个检查点只是超时,整个节点似乎只是“卡在”这个操作符上。有没有更好的方法来实现我在
Flink
想要做的事情?或者有什么方法来解决检查点问题?
浏览 5
提问于2021-12-22
得票数 0
回答已采纳
1
回答
集成测试
flink
作业
apache-flink
、
flink-streaming
我已经写了一个小的
flink
应用程序。我有一些输入,并用来自外部源的数据来丰富它。它是一个
RichAsyncFunction
,在open方法中,我构造了一个用于丰富的http客户端。
浏览 28
提问于2020-06-01
得票数 2
1
回答
我可以用
RichAsyncFunction
编写同步代码吗
apache-flink
、
flink-streaming
,我可以使用
RichAsyncFunction
。我写了下面的代码片段: public class SendGGSheetFunction extends
RichAsyncFunction
<Obj, String> { @Override
浏览 38
提问于2020-10-06
得票数 1
回答已采纳
1
回答
显示Apache计数器值,但未显示仪表值
apache-flink
、
flink-streaming
我们正在使用
Flink
1.8.0,并在EMR 上运行它,并希望测量吞吐量。在应用程序母版(即
Flink
的web用户界面)中,我们能够获得计数器的值,但不能得到仪表的值.。public class AsyncClass extends
RichAsyncFunction
<String, String> { private transient Counter counter
浏览 3
提问于2020-01-16
得票数 1
回答已采纳
3
回答
Apache
Flink
-异步刷新Hashmap
scala
、
apache-flink
我正在使用Scala API开发一个Apache
Flink
应用程序(我是一个使用这项技术的新手)。 我正在使用hashmap来存储来自数据库的一些值,并且我需要每隔一小时刷新这些值。
浏览 25
提问于2019-03-01
得票数 0
2
回答
如何使用bazel使用/导入
Flink
的TestHarness类?
maven
、
testing
、
apache-flink
、
bazel
、
flink-streaming
/external/maven/BUILD file我想使用Bazel构建工具测试我自己的异步
flink
流操作符
RichAsyncFunction
。:
flink
-core:%s" %
FLINK
_VERSION, "org.apache.<em
浏览 0
提问于2020-05-09
得票数 1
1
回答
DataSet --从Cassandra获取数据作为通用ResultSet,并将其转换为
Flink
apache-flink
、
flink-streaming
我尝试使用以下代码异步处理此查询:private static final Logger logger有什么想法在
Flink
中处理Cassandra ResultSet,或者我应该使用另一种技术来实现我的目标吗? 提前感谢大家的帮助!
浏览 8
提问于2017-12-21
得票数 0
1
回答
在
Flink
中使用异步I/O调用分页HTTP
apache-flink
、
flink-sql
、
flink-batch
我的问题是:有人知道怎么做吗?问候
浏览 14
提问于2022-08-31
得票数 0
1
回答
flink
接收器只支持生物吗?
asynchronous
、
nio
、
apache-flink
、
flink-streaming
例如返回Future 然后它会阻塞
flink
的任务线程,等待来自redis服务器的网络响应?!我知道
flink
有异步api,但它似乎不适用于接收器impl?
浏览 6
提问于2017-12-08
得票数 2
回答已采纳
1
回答
Apache :使用外部/阻塞调用的数据丰富流
apache-flink
、
flink-streaming
理论上,这是可行的,但我觉得这样做不好,因为我不知道如果流中有一些阻塞操作,
Flink
是如何反应的。如果有很多并行流阻塞,即我是否用完线程,会发生什么情况?
浏览 1
提问于2016-06-16
得票数 5
回答已采纳
1
回答
Apache :我如何从Cassandra读取DataStream/DataSet?
cassandra
、
apache-flink
@Jicaar在第一个链接中还提到,从
RichAsyncFunction
切换到RichMapFunction可以避免AsyncWaitOperator异常,有类似经验的人可以分享如何在RichMapFunctionat org.apache.
flink
.streaming.api.operators.async.Emitter.output(Emitter.java:137) [
flink
-streaming-java:504) ~[
flink
-streaming-java_2.11-1.4.2.jar:1.4.2]
浏览 0
提问于2018-04-03
得票数 2
回答已采纳
1
回答
用Postgres实现Spring + Apache项目
java
、
postgresql
、
spring-boot
、
apache-flink
、
flink-streaming
我希望避免使用spring依赖项来执行查找(即自动存储库),并希望继续使用
flink
实现进行查找。 我可以在哪里指定如何添加postgres连接配置信息,如端口、数据库、url、用户名、密码等。
浏览 4
提问于2020-05-26
得票数 0
回答已采纳
1
回答
除了一个胖jar之外,所有东西都会在停靠的
flink
集群中失败。
apache-flink
、
flink-streaming
flink
Dockerfile: ADD http://central.maven.org/maven2/org/apache/
flink
/
flink
-connector-kafkaorg/apache/
flink
/
flink
-avro-confluent-registry/1.7.2/
flink
-avro-con
浏览 0
提问于2019-04-12
得票数 1
回答已采纳
1
回答
是否有一种方法只将过滤过的事件从Apache流传递到AsyncDataStream/AsyncIO流?
apache-flink
AsyncDataStream.orderedWait(stringInputStream, lookupCodesInDB(), 3000, TimeUnit.MILLISECONDS, 100); return new
RichAsyncFunction
<String, JsonObject>() {
浏览 1
提问于2019-04-29
得票数 0
回答已采纳
2
回答
AbstractCassandraTupleSink的实现是不可序列化的。
java
、
cassandra
、
apache-flink
token, 1)); } } 运行这段代码后,我得到了以下错误: 线程"main“org.apache.
flink
.api.common.InvalidProgramException
浏览 0
提问于2018-12-24
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券