1回答
Flink json序列化时区问题
apache-flink、flink-streaming、flink-sql
我使用JsonRowSerializationSchema将Flink的行序列化为JSON。I SQL时间戳序列化存在时区问题。build()
{"c":"1969-12-31T16:00:00Z"}
我正在检查Flink实现，以下两种方法正在运行中
浏览 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
1回答
ZonedDateTime的Flink系列化
scala、apache-flink、zoneddatetime
我必须工作时区和纳米二次时间分辨率。因此，我使用ZonedDateTime。显然，Apache没有正确地序列化ZonedDateTime。它确实像预期的那样序列化LocalDateTime部件，但是它忘记了处理时区。例如，当我在Flink流映射函数中记录分区日期时，我总是得到以下内容而在数据开始时，我得到了正确的区域
2018-03-01T04我怎么才能解决这个问题呢？谢谢你的回复。
浏览 2提问于2018-05-01得票数 5
回答已采纳
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
问题是，当我想输入单词和计数卡桑德拉table.My程序是在以下：
} }运行这段代码后，我得到了以下错误：
线程"main“org.apache.flink.api.common.InvalidProgramException我搜索了很多，但是我找不到it.Would的任何解决方案，请告诉我如何解
浏览 0提问于2018-12-24得票数 0
回答已采纳
3回答
Flink流程序在处理时间内正确运行，但不会在事件时产生结果。
java、apache-flink、flink-streaming
更新添加了env.getConfig().setAutoWatermarkInterval(1000L);我想问题就在我代码的另一部分。所以首先要多了解一些背景。bootstrap.servers"),我试图使用Flink我不知道我哪里出了问题。
浏览 6提问于2016-12-06得票数 1
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
回答已采纳
2回答
: org.apache.flink.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache/flink/core/memory/MemorySegmentFactory:118)at org.apache.fl
浏览 0提问于2017-03-17得票数 2
1回答
需要帮助，以下错误，因为我似乎找不到什么是实际的问题。我试图在win10专业版的桌面上运行flink集群。文档：ADD build/libs/demoapp-service-all.jar /opt/flink/usrlib/demoapp-service-all.jarADD conf/flink-conf
浏览 2提问于2020-11-25得票数 3
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
回答已采纳
1回答
集群上的flink作业- java.lang.NoClassDefFoundError: KeyedDeserializationSchema
scala、kubernetes、apache-flink、flink-streaming
我正在尝试flink并在flink集群上部署作业时遇到异常(在kubernetes上)。设置斯卡拉- 2.11.12集群上的Flink对接图像-flink:1.4.2-scala_2.11-高寒ThisBuild / resolvers" %% "flink-scala" % flinkVersion % "provided",
"org.apache
浏览 1提问于2018-03-15得票数 0
1回答
如何调试Flink任务问题
scala、serialization、apache-flink、flink-streaming
嗨，我正在尝试运行一个flink scala应用程序，它从kafka读取，应用一些查找转换，然后写到kafka。我在当地测试过，效果很好。异常不清楚，堆栈跟踪也显示了任务管理器堆栈跟踪，因此不知道应用程序中的问题可能在哪里。这可能是序列化问题吗？是否有一种方法来调试这些问题，并在应用程序代码中找到有问题的实际点？at org.apache.flink.streaming.api.graph.StreamConfig.getTypeSeria
浏览 2提问于2021-09-01得票数 0
回答已采纳
1回答
在docker独立flink中启动任务时出现问题
java、docker、apache-flink
我们在Flink中开发了一个系统，该系统从目录中读取文件，按客户端对文件进行分组，并根据信息的类型，将这些文件推送到接收器。我们在本地机器上安装了Flink，它工作正常，没有任何问题。当我们转到详细信息时，在UI中显示如下：Flink dashboard screenshot 作业中的日志显示以下内容： 2021-10-15 12:13:50,247 INFO org.apache.flink.runtime.jobmaster.JobMasterrestart: always
浏览 449提问于2021-10-15得票数 1
回答已采纳
1回答
flink + Kafka + JSON
java、json、maven、intellij-idea、apache-flink
我正在尝试使用这个JSONKeyValueDeserializationSchema类测试一个Flink程序来读取来自Kafka的JSON数据。然而，我的Intellij找不到这个类。我的pom.xml <dependency> <artifactId<groupId>org.apache.flink</
浏览 12提问于2016-09-02得票数 0
回答已采纳
3回答
当flink上载带有流sql查询的作业时发出
sbt、apache-flink、flink-streaming、flink-sql
我使用了最新的flink版本(1.10.0)和sbt(1.3.7)。_*) => MergeStrategy.discard }在之后，flink客户端将使用默认的子优先解决顺序.如果用户jar有一些冲突依赖项，则会出现一些问题。我的问题是:如何解决这些冲突？此情况下有任何程序集合并策略建议吗？我会感谢你的帮助。
浏览 3提问于2020-02-27得票数 0
1回答
如何使用闪烁计数窗口
java、apache-flink
: org.apache.flink.util.StateMigrationException: State migration is currently not supported.at org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.create(HeapKeyedStateBackend.java:216):290) at j
浏览 17提问于2020-02-11得票数 0
3回答
无法访问windows上的Flink仪表板本地主机:8081
windows、localhost、apache-flink
我遵循安装Flink。我可以在没有任何问题的情况下启动集群Starting cluster.但我没有从我也不能通过本地主机访问仪表板:8081。
有一个较旧的存在这些问题，但是这个解决方案对我不起作用，因为所描述的conf文件显然已经不存在了。我的JAVA_HOME设置为C:\Progra~1\Java\jdk1.8.0_311，以避免程序文件中的空间问题。
浏览 60提问于2022-01-17得票数 0
3回答
使用maven依赖项触发版本不匹配
maven、apache-spark、apache-spark-2.0
</groupId> <version>1.3.2</version><dependency> <artifactId>flink-clients_2.11&
浏览 19提问于2017-11-28得票数 0
回答已采纳
1回答
Flink配置，避免每次提交作业时都上传扩展jar
apache-flink、hadoop-yarn、flink-streaming
Flink是否有避免每次提交作业时都上传扩展jars的配置，就像spark-submit中的spark.yarn.archive一样？我知道处理外部jars的方法，比如How to Reference the External Jar in Flink中的答案。例如fat jar、将jar复制到$FLINK/lib、-yt配置，但它们不够灵活或不够方便。
浏览 78提问于2019-10-14得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号