我想更新我的flink应用程序1.11.0 -> 1.13.2我的代码库由于StreamExecutionEnvironment.setStreamTimeCharacteristic，timeWindowRestartStrategies.fixedDelayRestart(20,10000L)) env.setStreamTimeCharacteristic= packets
.timeWindow(Time.
浏览 29提问于2021-08-16得票数 0
回答已采纳
1回答
StreamExecutionEnvironment see = StreamExecutionEnvironment.getExecutionEnvironment();
see.setStreamTimeCharacteristic
浏览 10提问于2016-09-19得票数 2
1回答
我对Apache Flink非常陌生。我正在使用v1.9.0。我想加入多个流。在运行下面的示例时，我将得到以下异常。15:18:51,839 INFO org.apache.flink.runtime.taskmanager.Task - Window(SlidingEventTimeWindows(2, 1), EventTimeTrigger, CoGroupWindowFunction) -> Sink: Print to Std. Out (3/4) (ebc7985691707417b57a391ac83104f9) swit
浏览 6提问于2020-02-03得票数 1
回答已采纳
ParameterTool parameterTool = ParameterTool.fromArgs(args);
env.setStreamTimeCharacteristicStreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeChara
浏览 6提问于2016-12-06得票数 1
我一直试图在Flink中使用CoGroupFunction连接两个流。S1.addSource(new FlinkKafkaConsumer010[String]("topic-1", schema, props)).assignAscendingTimestamps(_.time)val d = env
.addSource(new FlinkKafkaConsumer010[String]("topic-2", sch
浏览 2提问于2018-07-16得票数 0
我有四个事件UserEvent(id = "customer-1", lat = 2.0 , lng = 0.0 , ts = "2018-10-16T03:00:00.01Z"),
UserEvent(id = "customer-1", lat = 3.0 , lng = 0.0, ts = "2018-10-16T04:00:0
浏览 3提问于2018-10-16得票数 0
我看到一些奇怪的行为。我使用Flink 1.12编写了一些Flink处理器，并尝试让它们在Amazon EMR上工作。但是，Amazon EMR目前仅支持Flink 1.11.2。当我去降级时，我莫名其妙地发现水印不再传播了。 主题上只有一个分区，并行度设置为1。我是不是遗漏了什么？我觉得我快要疯了。 以下是Flink 1.12的输出： Topic:input partitions=1
(name=input, internal=false, partitions=(partition=0, leader=mycomputer:9092 (id: 0 rack: null), replica
浏览 39提问于2021-04-14得票数 1
回答已采纳
我尝试在我的数据流上执行一些Flink操作。但是我没有得到任何结果。有谁知道为什么不。谢谢你的帮助。 KeyedStream<Tuple2<String, Long>, Tuple> stream1 = stream.keyBy(0);
DataStream<Tuple3<Integer, String, Date>> stream2 = stream1.window(TumblingEventTimeWindows.of(Time.seconds(15))).a
浏览 15提问于2020-04-27得票数 0
回答已采纳
setCheckpointTimeout(10000); env.setStreamTimeCharacteristic
浏览 423提问于2020-08-21得票数 3
回答已采纳
我有过去事件时间的数据集01-12-2015 01:10:2001-12-2015 01:10:40我想为这个timeWindow申请timeWindow(Time.seconds(30))
浏览 3提问于2017-04-11得票数 0
回答已采纳
1回答
我试图加入apache中的两个流以获得一些结果。现在，我希望得到一个时间窗口中所有tweet数量中转发次数的百分比。Time windowSize = Time.seconds(15);
DataStream<Tuple2<String, Integer&
浏览 2提问于2018-10-04得票数 1
回答已采纳
我想加入两个流(json)来自卡夫卡制片人。如果我过滤数据，代码就能工作。但当我加入他们的时候，它似乎不起作用。我想要打印到控制台的连接流，但什么也没有出现。这是我的密码import org.apache.flink.streaming.api.scala._import org.apache.flink.streaming.util.serialization.SimpleStringS
浏览 2提问于2017-08-03得票数 1
回答已采纳
在许多旧版本的Flink代码中，我看到一行定义了一些时间特性的代码，如：env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
然而
浏览 12提问于2022-02-02得票数 0
回答已采纳
我使用的是Flink 1.12，我已经将时间特征指定为事件时间，如下所示： env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
浏览 37提问于2021-04-30得票数 0
回答已采纳
1回答
时间戳的flink窗口
、、、
我有像这样的数据流在这里，我想应用窗口转换的最后一个字段Start_time是时间戳，我的要求是，我想获取最后30分钟的数据。我想取start_time持续30分钟的数据，然后我是如何写这个转换的？我需要使用该列使用filter吗？谢谢
浏览 2提问于2017-05-18得票数 0
我也是Flink和流媒体的新手。我正在使用5秒大小的滑动窗口和1秒滑动来计算消息的数量(下面的校验码)，但我需要帮助保存(或打印)延迟到达的丢弃消息，我尝试使用sideOutputLateData，但它对我不起作用 .assignTimestampsAndWatermarks(new SensorTimeAssigner) .keyBy(x => (x._1, x._2))
.timeWindow(Time.seconds(5)
浏览 7提问于2019-11-12得票数 0
1回答
我有很多事件都有自己的时间戳。我需要将这个流划分为1分钟，而不是重叠的窗口，并执行一些计算。我对弗林克非常陌生，但我想出了这样的办法：不过，我不知道如何实现这个窗口，从一分钟开始就开始，而不是在执行时。
浏览 5提问于2016-04-22得票数 0
回答已采纳
1回答
Pattern<Event, ?> pattern = Pattern.<Event>begin("start") @Override return value.getName().equals("error");
浏览 2提问于2018-05-15得票数 1
回答已采纳
MyWindowAssigner()).process(new MyProcessWindowFunction());env.setStreamTimeCharacteristic
浏览 24提问于2021-05-24得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
