我从apache-flink sql-client提交了一个作业，并创建了一个保存点。问题是元数据不包含jar和类名，更不用说参数了。如何重启？
浏览 4提问于2021-03-19得票数 0
1回答
'GlobalWindowAggregate(groupBy=[org, $f4], window=[HOP(slice_end=[$slice_end], size=[15 min], slide=[1 min])], select=[org, $f4, COUNT(distinct$0 count$0) AS $f2, COUNT(count1$1) AS window_start, start('w$) AS window_end]) -> Calc(select=[window_start
浏览 30提问于2021-12-05得票数 0
当前Flink代码：import org.apache.flink.streaming.api.windowing.assigners.GlobalWindowsimport org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.streaming.api.windowing.triggers.Trigger.Trig
浏览 4提问于2017-03-13得票数 1
回答已采纳
这是我的代码：import org.apache.flink.streaming.api.scala.entity => (entity.id, entity.attrs("temperature").value.asInstanceOf[String])) .windowTime.seconds(10), Time.seconds(5)))
.process(new
浏览 1提问于2018-11-30得票数 6
我在flink中有一个地图，一旦数据通过流，它就会被激活。 即使没有数据通过，我也要调用该地图。 我将map移动到一个函数中(无限函数调用)，但是flink作业永远不会运行。这个想法是，在一个无限循环中有一个映射，检查一些共享变量，另一个flink流监控kafka队列，如果数据进入它的进程，它会改变一个共享变量，以某种方式影响无限循环并继续。如何调用无限循环映射并同时运行flink映射？我尝试使用随机数据创建一个CollectionMap来激活流和映射以调用无限循环，但几乎立即退出，即使映射中存在while(true)条件
浏览 28提问于2019-05-07得票数 1
window(GlobalWindows.create()).{Trigger, TriggerResult}
override def onElement(element: Session, timestamp: Long): TriggerResult =
浏览 3提问于2017-03-24得票数 2
回答已采纳
org.apache.flink.streaming.api.TimeCharacteristic
浏览 26提问于2020-06-26得票数 0
回答已采纳
import org.apache.flink.api.scala._import org.apache.flink.streaming.apiwith 1.5 second gap
.window(EventTimeS
浏览 1提问于2019-08-29得票数 1
回答已采纳
我想在processwindowfunction中设置状态的TTL。此状态在窗口之间共享。此TTL需要基于事件本身中的属性。所以我不能计算状态描述符中的TTL。此外，在processwindowfunction中不支持onTimer函数。 有没有其他方法可以做到这一点？
浏览 15提问于2021-04-08得票数 0
回答已采纳
1回答
我希望使用早期触发逻辑进行窗口聚合(您可以认为该聚合是由窗口关闭或由特定事件触发的)，我在doc：上阅读了我的问题是，AverageAggregate在文档中，状态没有保存到任何地方，所以如果应用程序崩溃，averageAggregate将释放所有中间值，对吗？
因此，如果是这样的话，是否有一种方法可以进行窗口聚合，仍然支持增量聚合，并且有状态后端可以从崩
浏览 3提问于2021-02-18得票数 0
回答已采纳
我看了一下flink，我们有一些方法可以做到这一点，例如使用ProcessWindow函数，增量聚合，流切片，广播状态等，但由于我对flink非常陌生，我不完全确定要使用什么，以及是否有任何我遗漏的陷阱
浏览 3提问于2020-10-01得票数 1
我正在使用Flink 1.12并且我有一个键控流，在我的代码中看起来A和B共享相同的水印？import org.apache.flink.streaming.api.scala.import org.apache.flink.streaming.api.windowing.time.Time val end = to_char(window.getEnd)
浏览 12提问于2021-05-02得票数 0
回答已采纳
Flink流支持内部连接表达式，如window- join，interval-join.但不支持左联接/完全联接表达式。我的问题是：.leftJoin().window()
.apply()
浏览 3提问于2021-08-15得票数 0
回答已采纳
), (Int, String, Int, Long), (Int, String), TimeWindow] { for(row<- in) {
out.collect((row._1, row._2, row._3, window.maxTim
浏览 2提问于2016-04-28得票数 3
回答已采纳
为了探索Flink表API在当前项目中使用的可能性和局限性，我试图将Flink SQL语句转换为其等效的Flink表API版本。Flink表API (不工作) .window(Over.partitionBy($("COLUMN_A"))
.orderBy($("EVENT_TIME").desc
浏览 13提问于2022-08-16得票数 0
回答已采纳
我修改了Flink的基本wordcount示例，并使用窗口函数进行了播放。.flatMap { w => w.split("\\s") } .keyBy(t => "all") override def apply(key: String, windo
浏览 3提问于2017-11-24得票数 1
回答已采纳
2回答
Int), String, TimeWindow] { key: Tuple,
window, Iterable[((String, com.flink.Response), Int)], org.apache.flink.util.Collector[R]) => Unit)(implicit, com.flink.Response), Int),(String, com.flink</em
浏览 18提问于2019-05-02得票数 1
在此过程中，我选择将org.apache.flink.streaming.api.functions.windowing.WindowFunction用于特定的用例。import org.apache.flink.streaming.api.windowing.windows.MyWindowFunction extends WindowFunction[(String, Long), String, String, TimeWindow] {
var
浏览 2提问于2016-09-09得票数 2
1回答
我想使用flink的作业管理器报告的指标。像这样的东西，但这不像我喜欢的那样工作。(timestamp(flink_taskmanager_job_task_operator_currentInputWatermark{task_name=~"my_window.*"})-(4*60*60*1000))-flink_taskmanager_job_task_operator_currentInputWatermark{task_name=~"my_window.*"
浏览 20提问于2020-05-12得票数 0
回答已采纳
")(2), count = 1)) .keyBy(l => l.id) //.window(SlidingProcessingTimeWindows.of我的flink版本是1.14
浏览 6提问于2021-12-23得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
