已有0人关注此标签
作者: 何不留下昵称和大家交个朋友
290人浏览
0人回答
本地sock测试AggregateFunction 生效 但是上了flink集群后(连接的kafka源 ,数据能正常收到) 发现AggregateFunction 的getresult方法不触发,而createAccumulator和a…
作者: 一码平川MACHEL
258人浏览
1人回答
我有一个带有npartition = 8的dask数据帧,这里是数据的快照: id1 id2 Page_nbr record_type St1 Sc1 3 START …
作者: 欢乐小母鳄
296人浏览
1人回答
图片 kafka-clients与ons-sasl-client版本不配套,有没有配套的ons-sasl-client
作者: 一码平川MACHEL
392人浏览
1人回答
据我所知,__add__可以用来定义+新类的用法。定义使用的等价物是[]什么? 我想创建一个Parent包含字典的类,codes我想Parent[key]返回Parent.codes[key] 我理解我可能只是使用Parent.codes…
作者: 一码平川MACHEL
231人浏览
1人回答
据我所知,__add__可以用来定义+新类的用法。定义使用的等价物是[]什么? 我想创建一个Parent包含字典的类,codes我想Parent[key]返回Parent.codes[key] 我理解我可能只是使用Parent.codes…
作者: 一码平川MACHEL
378人浏览
1人回答
我目前正在尝试制作一个机器人,允许成员设置机器人然后在服务器中检查的特定关键字(在一段时间内)。如果机器人在消息中检测到该关键字(仅通过另一个bot / webhook),它会警告设置该关键字的用户。 基本上我想做的是像这样的场景: 会员…
作者: 一码平川MACHEL
274人浏览
1人回答
我的代码: class DataSourceCreateView(CreateView): model = DataSource form_class = DataSourceForm template_name = 'engine/da…
作者: 一码平川MACHEL
442人浏览
1人回答
'distributions'列对应于一个独特的方程组,我试图将其压缩成SageMath中的一系列数字。'probs'列对应于是否应该根据它所在的行和列,通过给定的单项式来给定方程式多余。上面仅用于概述,与我的实际问题无关。 无论如何,这…
作者: 社区小助手
282人浏览
1人回答
我已经实现了累加器来查看代码中的事件计数。但我无法在Spark UI中看到它们。我使用以下东西: val count_Of_2317508_1 = sc.longAccumulator("count_Of_2317508_1") cou…
作者: flink小助手
553人浏览
1人回答
我正在使用Apache Flink v1.6.0,我正在尝试写入Elasticsearch v6.4.0,它存放在Elastic Cloud中。我在向Elastic Cloud集群进行身份验证时遇到问题。 我已经能够让Flink写入本地E…
作者: robert.zhu
378人浏览
1人回答
我在opennms 官方网站上找到监控AD域服务目录的代码,但根据要求添加后没有办法打开opennms 的主页。这个是为什么!求解。注:启动的时候没有报错。 Monitoring the services To monitor the s…