Re:Re: CustomKafkaDeserializationSchema is abstrct

FlinkKafkaConsumer> consumer = new FlinkKafkaConsumer<>( topic, new CustomKafkaDeserializationSchema(), props ); public class CustomKafkaDeserializationSchema implements KafkaDeserializationSchema> { @Override public boolean

回复：退订

Hi 退订应该发送到 user-zh-unsubscr...@flink.apache.org Best JasonLee 在2021年09月14日 11:46，abel0130 写道： 退订

回复：flink on native k8s 无法查看火焰图问题

Hi 这个配置默认是关闭的,因为对性能有一定影响,具体的配置可以参考官网 https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/#advanced-options-for-the-rest-endpoint-and-client Best JasonLee 在2021年09月14日 11:20，赵旭晨 写道： Unable to load requested file /jobs/d2fcac59f4a42ad17ceba8c5371862bb/。。

退订

退订

回复：flink on native k8s 无法查看火焰图问题

开启这个参数：rest.flamegraph.enabled: true | | johnjlong | | johnjl...@163.com | 签名由网易邮箱大师定制 在2021年9月14日 11:29，赵旭晨 写道： Unable to load requested file /jobs/d2fcac59f4a42ad17ceba8c5371862bb/。。 请问这是什么原因啊，恳请大佬解惑 镜像版本flink:1.13.2-scala_2.12-java8

退订

退订

flink on native k8s 无法查看火焰图问题

Unable to load requested file /jobs/d2fcac59f4a42ad17ceba8c5371862bb/。。 请问这是什么原因啊，恳请大佬解惑 镜像版本flink:1.13.2-scala_2.12-java8

Re: CustomKafkaDeserializationSchema is abstrct

Hi！ 邮件里看不到图片，请检查一下。 从标题来看，是不是写了一个自己的 kafka deserialization schema，然后这个类是 abstract class，不能直接 new？ 赢峰 于2021年9月13日周一 下午8:57写道： > 报错如下： > > > 代码如下： > > > > 签名由 网易邮箱大师 定制 > >

CustomKafkaDeserializationSchema is abstrct

报错如下： 代码如下： 签名由网易邮箱大师定制

Re: 请教Cumulate Windows问题

Hi！ 你可能想要的是 tumble window，具体见 https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/queries/window-agg/ xiaocuyu 于2021年9月13日周一 上午11:56写道： > 各位社区大佬： > 您好！ > 在使用Flink SQL中，我有一个需求是：对当天所有的数据进行聚合，然后固定时间输出聚合结果，目前感觉Cumulate >