腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Flink
json序列化
时区
问题
apache-flink
、
flink-streaming
、
flink-sql
我使用JsonRowSerializationSchema将
Flink
的行序列化为JSON。I SQL时间戳序列化存在
时区
问题。build() {"c":"1969-12-31T16:00:00Z"} 我正在检查
Flink
实现,以下两种方法正在运行中。return c
浏览 7
提问于2020-11-17
得票数 1
2
回答
在
flink
中使用翻滚的Windows时,我可以为每个键设置不同的
时区
偏移量吗?
apache-flink
、
flink-streaming
作为
flink
文档中的示例:.keyBy(<key selector>)我想为每个键设置不同的偏移量,因为它有不同的
时区
。我怎么能这么做?
浏览 0
提问于2018-05-23
得票数 0
回答已采纳
1
回答
如何获取作业提交时间并在
Flink
应用程序中使用?
apache-flink
、
flink-streaming
、
flink-cep
、
flink-sql
、
flinkml
我目前正在开发一个流处理应用程序,其中一个功能是获取在提交作业的
时区
时间内发生的事件,提交作业的时间+T。谢谢。
浏览 14
提问于2020-05-24
得票数 0
2
回答
如何在
flink
SQL中使用ISO-8601日期?
sql
、
casting
、
timestamp
、
apache-flink
根据我的研究,
Flink
SQL接受"0000-01-01 : 00:00:00.000000000“作为时间戳格式,但我的卡夫卡时间戳是”0000-01-01T00:00:00:00.000000000“格式,这会导致
flink
sql查询失败。是否有办法将日期的格式(例如2022-05-02T18:28:07.8814Z)转换成
flink
中所需的格式?在其他SQL语言中,这将是一个非常简单的操作,但通过阅读
Flink
文档,我无法找到一种方法。 我试着做一个字符串替换,并将字符串转换为时间戳,但是它没有工作。我
浏览 19
提问于2022-05-06
得票数 1
回答已采纳
1
回答
ZonedDateTime的
Flink
系列化
scala
、
apache-flink
、
zoneddatetime
我必须工作
时区
和纳米二次时间分辨率。因此,我使用ZonedDateTime。显然,Apache没有正确地序列化ZonedDateTime。它确实像预期的那样序列化LocalDateTime部件,但是它忘记了处理
时区
。例如,当我在
Flink
流映射函数中记录分区日期时,我总是得到以下内容而在数据开始时,我得到了正确的区域 2018-03-01T04
浏览 2
提问于2018-05-01
得票数 5
回答已采纳
3
回答
Flink
流程序在处理时间内正确运行,但不会在事件时产生结果。
java
、
apache-flink
、
flink-streaming
bootstrap.servers"),我试图使用
Flink
浏览 6
提问于2016-12-06
得票数 1
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
1
回答
Flink
与kafka Sink未能执行: java.lang.LinkageError:加载程序约束违反
java
、
apache-kafka
、
apache-flink
:
flink
-annotations</exclude> <exclude>org.apache.<
浏览 0
提问于2018-11-19
得票数 0
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
回答
如何从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
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何修改mysql时区
Tomcat容器如何设置时区
Flink基础教程(二):初探Flink
如何修改CDSW会话的时区
Apache Flink 进阶(六):Flink 作业执行深度解析
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券