腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Flink
中保持HashMap进入状态的最佳方法是什么?
java
、
apache-flink
、
flink-streaming
、
flink-cep
我有一个
Flink
作业,其中一个statefull操作符需要保持一个包含HashMap作为属性的类的状态,因为这个hasMap为用户保留了不同的亲缘关系,例如:这是一个坏主意,还是有更好的方法来做到这一点,并保持对象的状态?在一个完整的例子中,我或多或少需要做些什么,但不确定是否将HashMap用于
Flink
运算符和状态是一个好主意: public class AffinityF
浏览 0
提问于2020-09-04
得票数 2
1
回答
如何在类路径中找到实现'org.apache.
flink
.table.factories.DynamicTableFactory‘的标识符'elasticsearch-7’的工厂
python
、
elasticsearch
、
pyflink
_2.12-1.13.1.jar;file:///path_to/
flink
-sql-connector-elasticsearch7_2.11-1.13.1") user_id STRING,
uv
BIGINT, pv BIGINT:找不到在类路径中实现'org.apache.
flink
.table.fac
浏览 16
提问于2022-03-30
得票数 0
1
回答
按over非时间戳列分组的流
Flink
SQL
apache-flink
、
flink-streaming
、
flink-sql
broker address);INSERT INTO cumulative_
uv
FROM ( D
浏览 1
提问于2021-09-12
得票数 0
1
回答
Apache :如何在滚动时间窗口中使用DISTINCT?
apache-flink
、
flink-streaming
、
flink-sql
SELECT tumble_start(_time, interval '10' second) as timestart, " + " count(distinct userId) as
uv
at org.apache.
flink
.table.codegen.CodeGenerator$$anonfun$visitCall$3.apply(CodeGenerator.scala:1006)at org.apache.
flink
.table.codegen.CodeGenerator$
浏览 1
提问于2018-03-02
得票数 1
1
回答
如何在每次窗口完成时让
Flink
写到HDFS?
hdfs
、
apache-flink
、
real-time
我是
Flink
的初学者,我的问题是,我的
Flink
应用程序消耗了一个实时的流量,我想收集每一个‘自然’小时流量的
uv
,然后将agg结果写到HDFS。
浏览 2
提问于2022-01-04
得票数 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
回答已采纳
2
回答
AbstractCassandraTupleSink的实现是不可序列化的。
java
、
cassandra
、
apache-flink
token, 1)); } } 运行这段代码后,我得到了以下错误: 线程"main“org.apache.
flink
.api.common.InvalidProgramException
浏览 0
提问于2018-12-24
得票数 0
回答已采纳
2
回答
Apache 1.14.0 -无法通过Java中的SQL使用python
apache-flink
、
user-defined-functions
、
flink-table-api
input_types=[DataTypes.INT()], result_type=DataTypes.INT()) return a + 1➜
flink
-1.14.0 .ret1 = tEnv.executeSql("select add1(3)"); }然后通过
Flink
客户端运行作业:
flink
run
浏览 6
提问于2021-12-03
得票数 3
1
回答
找不到org.apache.
flink
.streaming.api.scala.DataStream的Apache类文件
apache-flink
、
flink-streaming
我使用代码中导入的下列依赖项:import org.apache.
flink
.api.java.tuple.Tuple2;import org.apache.
flink
.streaming.api.environment.StreamExecutionEnvironment; impo
浏览 2
提问于2018-03-24
得票数 4
回答已采纳
2
回答
intellij找不到
Flink
测试Harness util
java
、
testing
、
intellij-idea
、
apache-flink
我试图使用Apache (org.apache.
flink
.streaming.util.OneInputStreamOperatorTestHarness)中的OneInputStreamOperatorTestHarness
浏览 5
提问于2021-12-20
得票数 -1
2
回答
使用卡夫卡主题时的org.apache.
flink
.streaming.api.checkpoint.CheckpointNotifier :ClassNotFoundException
apache-kafka
、
apache-flink
、
flink-streaming
我使用的是最新的
Flink
-1.1.2-Hadoop-27和
flink
-连接器-kafka-0.10.2-Hadoop 1罐。
Flink
消费者如下:以下是执行后得到的例外情况: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache&
浏览 2
提问于2016-10-14
得票数 7
回答已采纳
2
回答
IntelliJ集成开发环境警告
Flink
CEP未知错误
scala
、
intellij-idea
、
apache-flink
、
complex-event-processing
我开始研究用Scala语言编写的Apache
Flink
的CEP库,当我试图通过执行https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/
flink
-cep-scala libraryDependencies += "org.apache.
flink
" %% "
flink
-cep-scala" % "1.9
浏览 50
提问于2020-01-14
得票数 0
回答已采纳
1
回答
Flink
群集启动错误:无法解决ResourceManager地址akka
flink-sql
我试图在win10专业版的桌面上运行
flink
集群。文档:ADD build/libs/demoapp-service-all.jar /opt/
flink
/usrlib/demoapp-service-all.jarADD conf/
flink
-conf.yaml /opt/
flink
&
浏览 2
提问于2020-11-25
得票数 3
1
回答
Flink
与kafka Sink未能执行: java.lang.LinkageError:加载程序约束违反
java
、
apache-kafka
、
apache-flink
:
flink
-annotations</exclude> <exclude>org.apache.<
浏览 0
提问于2018-11-19
得票数 0
1
回答
如何从Kubernetes中的
flink
docker镜像启动我的jar应用程序?
docker
、
kubernetes
、
apache-flink
我用maven编译了我的项目https://github.com/felipegutierrez/explore-
flink
,并用这个Dockerfile扩展了默认的
flink
图像
flink
:1.11.1/java/explore-
flink
/opt/explore-
flink
RUN mvn clean install FROM
浏览 89
提问于2020-09-21
得票数 1
回答已采纳
2
回答
如何使用
Flink
的TestHarness类?
unit-testing
、
apache-flink
通过阅读,我得出结论,我应该使用per:https://ci.apache.org/projects/
flink
/
flink
-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling我原以为它可能是在
flink
-test-utils-junit中实现的,但事实并非如此。
浏览 104
提问于2019-02-16
得票数 0
回答已采纳
1
回答
波束闪动: org.apache.beam.runners.
flink
.translation.wrappers.streaming.WorkItemKeySelector :ClassNotFoundException
java
、
apache-flink
、
apache-beam
、
flink-streaming
我正在尝试使用光束和
Flink
runner设置一个流处理管道。
Flink
是具有以下docker-compose文件的本地会话部署: version: "3" jobmanager: container_name:
flink
-jobmanager
FLINK
_PROPERTIES: "jobmanager.rpc
浏览 94
提问于2021-01-29
得票数 3
2
回答
在Scala中找不到RestHighLevelClient
scala
、
elasticsearch
、
apache-flink
、
resthighlevelclient
我的目标是从
Flink
获得一个流,并将其插入到ElasticSearch中,感谢您的帮助。
浏览 0
提问于2020-02-05
得票数 0
1
回答
Flink
1.12找不到在类路径中实现'org.apache.
flink
.table.factories.DynamicTableFactory‘的标识符“kafka”的任何工厂
apache-flink
我有一个在本地运行良好的
Flink
作业,但是当我尝试在集群上
flink
run作业时失败了。它基本上是读卡夫卡,做一些转换,并写到一个水槽。这是我的pom.xml,包括
flink
-connector-kafka。 </dependency> <groupId>org.apache.
flink</e
浏览 16
提问于2021-03-10
得票数 0
回答已采纳
2
回答
出现java.lang.NoSuchMethodError异常的Flick WordCount示例失败
apache-flink
: org.apache.
flink
.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache/
flink
/core/memory/MemorySegmentFactory:118)at org.apache.
fl
浏览 0
提问于2017-03-17
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券